Kura Kafka sastāvdaļa nodrošina to pašu ziņojumu atkārtotas lasīšanas novēršanu?

Kafka aizkavēšanās novēršana, atkārtoti lasot tās pašas ziņas, tiek nodrošināta ar nobīdes (offsets) mehānismu un to pārvaldību klienta (consumer) pusē.

Katram ziņojumam sadaļā ir unikāls nobīdes skaitlis — secības numurs. Klients seko līdzi, kuru nobīdes skaitli tas jau ir izlasījis un apstiprina (commit). Pārlādējot, klients sāk lasīt no pēdējā apstiprinātā nobīdes skaitļa, tādējādi novēršot jau apstrādāto ziņu atkārtotu lasīšanu.

Tādējādi, komponenta, kas ir atbildīgs par atkārtotas lasīšanas novēršanu, ir pats klients, kas pārvalda commit nobīdes.