Která součást Kafka zajišťuje prevenci opakovaného čtení stejných zpráv?

V Kafka je prevence opakovaného čtení stejných zpráv zajištěna mechanismem posunů (offsetů) a jejich správou na straně spotřebitele.

Každá zpráva v partition má unikátní offset — pořadové číslo. Spotřebitel sleduje, který offset již přečetl, a potvrzuje ho (commit). Při restartu začíná číst od posledního potvrzeného offsetu, čímž se vyhýbá opakovanému čtení již zpracovaných zpráv.

Tímto je komponenta odpovědná za prevenci opakovaného čtení, samotný spotřebitel, který spravuje commit offsety.