Kus Kafka sees salvestatakse tarbitud sõnumite Offset väärtus?

Apache Kafka-s säilitatakse tarbitud sõnumite Offset väärtus spetsiaalses sisemises teemas nimega __consumer_offsets. See teema hoiab teavet iga tarbija (consumer group) praeguse positsiooni kohta iga teema jaotises (partition).

Seega Kafka ei salvesta offseti kliendi kohaliku seadistuse kaudu, vaid keskse klastrina, mis võimaldab tarbijatel taastuda ja jätkata lugemist vajalikust positsioonist.

Lisaks võivad kliendid offseti käsitsi (commit) või automaatselt salvestada, sõltuvalt tarbija seadistustest.

Näide Go keeles confluent-kafka-go teegiga offsetide commitimiseks:

consumer.CommitMessage(message)

kus message on loetud sõnum, mille offset salvestatakse.