Kafka'da xabar o'qilganligini qanday aniqlash mumkin?

Kafka'da xabar o'qilganligi faktini, mavzuning partitionlardagi (offsetlar) yordamida aniqlash mumkin. Har bir iste'molchi (consumer) har bir partitionda o'qigan offsetini kuzatib boradi.

Xabar o'qilganligini aniqlash uchun:

• Iste'molchi xabarni muvaffaqiyatli ishlaganligiga ishonch hosil qilish.
• Bu xabar offsetini Kafka'da tasdiqlash (commit), ya'ni brokerga barcha xabarlar shu offsetgacha ishlanganligini bildirish.

Go tilida, Kafka mijozidan (masalan, sarama yoki confluent-kafka-go) foydalanib, xabarlar ishlov berilgandan so'ng offsetlarni aniq tasdiqlash mumkin. Agar offset tasdiqlansa, xabar o'qilgan hisoblanadi va bu iste'molchiga yana yetkazilmaydi.

Misol sarama bilan (soddalashtirilgan):

consumer.MarkMessage(msg, "") // Xabarni o'qilgan sifatida belgilash
consumer.CommitOffsets()       // Offsetlarni tasdiqlash

Shu tarzda, xabar o'qilganligi faktini, Kafka'da muvaffaqiyatli offset commit qilish bilan aniqlash mumkin.