Milline Kafka komponent tagab sama sõnumite kordusloetava vältimise?

Kafka puhul on sama sõnumi korduv lugemise vältimine tagatud offset-mehhanismi ja nende haldamisega kliendi (consumer) poolel.

Iga sõnum partition'is omab unikaalset offset-i — järjekorranumbrit. Kliendi jälgib, millist offset-i ta on juba lugenud ja kinnitab seda (commit). Taaskäivitamisel alustab ta lugemist viimase kinnitatud offset-i juurest, vältides seega juba töödeldud sõnumite korduvat lugemist.

Seega, komponent, mis vastutab korduva lugemise vältimise eest, on ise consumer, kes haldab commit offset-e.