Kafka, pasikartojančio tų pačių pranešimų skaitymo prevencija užtikrinama naudojant poslinkių (offsets) mechanizmą ir jų valdymą kliento (consumer) pusėje.

Kiekvienas pranešimas partition'e turi unikalų offset'ą — eilės numerį. Klientas stebi, kurį offset'ą jis jau perskaitė ir patvirtina (commit). Paleidus iš naujo, klientas pradeda skaityti nuo paskutinio patvirtinto offset'o, taip išvengdamas pakartotinio jau apdorotų pranešimų skaitymo.

Taigi, komponentas, atsakingas už pakartotinį skaitymo prevenciją, yra pats klientas, kuris valdo commit offset'us.

Ankstesnis Kitas