Melyik Kafka-komponens biztosítja ugyanazon üzenetek újraolvasásának megelőzését?

A Kafka-ban az ismételt üzenetolvasás megelőzése a szökkenések (offsets) mechanizmusával és azok fogyasztói oldalról történő kezelésével biztosított.

Minden üzenet egy partíciónak egyedi offsettel rendelkezik — egy sorszám. A fogyasztó nyomon követi, mely offsetet olvasta már, és megerősíti (commit). Újraindításkor a fogyasztó az utolsó megerősített offsettől kezdve olvas, így elkerülve az már feldolgozott üzenetek ismételt olvasását.

Így a felelős komponens az ismételt olvasás megelőzéséért maga a fogyasztó, amely a commit offseteket kezeli.