Jak Kafka obsługuje wiadomości, które nie zostały pomyślnie przetworzone?

W Kafka wiadomości są zapisywane w topikach i konsumowane przez subskrybentów. Jeśli wiadomość nie została pomyślnie przetworzona przez konsumenta, Kafka sama nie usuwa jej z topiku, a pozostawia ją dostępną do ponownego odczytu.

Obsługa nieudanych wiadomości jest zwykle realizowana po stronie konsumenta:

• Konsument może nie zatwierdzać (commit) przesunięcia (offset) wiadomości, co spowoduje jej ponowne odczytanie przy następnym uruchomieniu.
• Można używać mechanizmów ponawiania prób lub wysyłać problematyczne wiadomości do osobnego topiku "dead-letter" do dalszej analizy.

W ten sposób Kafka zapewnia niezawodne przechowywanie wiadomości, a logika obsługi błędów i ponownych prób jest realizowana w aplikacji-konsumenta.