Który komponent Kafka zapewnia zapobieganie ponownemu odczytowi tych samych wiadomości?

W Kafka zapobieganie ponownemu odczytowi tych samych wiadomości jest zapewnione przez mechanizm przesunięć (offsets) i zarządzanie nimi po stronie konsumenta.

Każda wiadomość w partycji ma unikalny offset — numer porządkowy. Konsument śledzi, który offset już odczytał i zatwierdza go (commit). Po ponownym uruchomieniu, konsument zaczyna odczyt od ostatniego zatwierdzonego offsetu, unikając ponownego odczytu już przetworzonych wiadomości.

W związku z tym, komponentem odpowiedzialnym za zapobieganie ponownemu odczytowi jest sam konsument, który zarządza commit offsetami.