Ce component Kafka asigură prevenirea citirii repetate a acelorași mesaje?

În Kafka, prevenirea citirii repetate a acelorași mesaje este asigurată prin mecanismul de offset-uri și gestionarea acestora pe partea consumatorului.

Fiecare mesaj dintr-o partiție are un offset unic — un număr de ordine. Consumatorul urmărește ce offset a citit deja și îl confirmă (commit). La repornire, consumatorul începe citirea de la ultimul offset confirmat, evitând astfel citirea repetată a mesajelor deja procesate.

Prin urmare, componenta responsabilă pentru prevenirea citirii repetate este chiar consumatorul, care gestionează offset-urile de commit.