Koji deo Kafka obezbeđuje sprečavanje ponovnog čitanja istih poruka?

U Kafka, sprečavanje ponovnog čitanja istih poruka obezbeđeno je mehanizmom pomaka (offsets) i njihovim upravljanjem na strani potrošača.

Svaka poruka u particiji ima jedinstveni offset — redni broj. Potrošač prati koji offset je već pročitao i potvrđuje ga (commit). Pri ponovnom pokretanju, potrošač počinje čitanje od poslednjeg potvrđenog offseta, čime izbegava ponovo čitanje već obrađenih poruka.

Dakle, komponenta odgovorna za sprečavanje ponovnog čitanja je sam potrošač, koji upravlja commit offset-ima.