Junior — Middle
Kafka içinde, tüketilen mesajlar için Offset değeri nerede saklanır?
sobes.tech yapay zeka
AI'dan gelen yanıt
Apache Kafka'da, tüketilen mesajlar için Offset değeri, __consumer_offsets adlı özel bir dahili konuya kaydedilir. Bu konu, her tüketicinin (tüketici grubu) her bölümdeki (partition) mevcut konumuyla ilgili bilgileri tutar.
Bu nedenle, Kafka offset'i istemciye yerel olarak kaydetmez, bunun yerine kümede merkezi olarak saklar, bu da tüketicilerin kendilerini kurtarmasına ve ihtiyaç duyulan konumdan okumaya devam etmesine olanak tanır.
Ayrıca, müşteriler offset'i manuel (commit) veya otomatik olarak kaydedebilir, bu tüketicinin ayarlarına bağlıdır.
Go dilinde confluent-kafka-go kütüphanesi kullanılarak offset commit örneği:
consumer.CommitMessage(message)
Burada message, okunmuş mesajdır ve offset'i kaydedilecektir.