Kafka ичинде керектелген билдирүүлөр үчүн Offset мааниси кайда сакталат?

Apache Kafkaда, колдонулган билдирүүлөр үчүн Offset мааниси __consumer_offsets деп аталган атайын ички темада сакталат. Бул тема ар бир керектүү топтун (consumer group) ар бир бөлүмүндө (partition) учурдагы жайгашкан жерин сактайт.

Ошентип, Kafka оффсетти жергиликтүү кардарда сактабайт, тескерисинче, кластерде борборлоштурган түрдө сактайт, бул керектөөчүлөргө өздөрүн калыбына келтирүүгө жана керектүү позициядан окууга улантууга мүмкүндүк берет.

Мындан тышкары, кардарлар оффсетти кол менен (commit) же автоматтык түрдө сактай алышат, бул керектөөчүнүн жөндөөлөрүнө жараша.

Go тилинде confluent-kafka-go китепканасы аркылуу оффсетти commit кылуу мисалы:

consumer.CommitMessage(message)

башкача айтканда, message окулган билдирүү болуп, анын оффсети сакталат.