Kafka ichki qaysi joyda iste'mol qilingan xabarlar uchun Offset qiymati saqlanadi?

Apache Kafka'da, istehlak qilinayotgan xabarlar uchun Offset qiymati __consumer_offsets nomli maxsus ichki mavzuda saqlanadi. Bu mavzu har bir iste'molchi (iste'molchi guruhi)ning har bir bo'limdagi (partition) hozirgi holatini saqlaydi.

Shunday qilib, Kafka offsetni mijozda mahalliy tarzda saqlamaydi, balki klasterda markazlashtirilgan holda saqlaydi, bu esa iste'molchilarga o'zlarini tiklash va kerakli pozitsiyadan o'qishni davom ettirish imkonini beradi.

Bundan tashqari, mijozlar offsetni qo'lda (commit) yoki avtomatik ravishda saqlashlari mumkin, bu iste'molchining sozlamalariga bog'liq.

Go tilida confluent-kafka-go kutubxonasi yordamida offsetlarni commit qilish misoli:

consumer.CommitMessage(message)

bu yerda message o'qilgan xabar bo'lib, uning offseti saqlanadi.