Чӣ тавр метавон муайян кард, ки паёме дар Kafka хонда шудааст?

Дар Kafka, ҳақиқати ки хабар ўқилганлиги offsetлар (offsets) ёрдамида белгиланади. Ҳар бир истеъмолчи (consumer) ҳар бир partitionда ўқилган offsetни кузатиб боради.

Хабар ўқилганлиги ҳақиқатига эга бўлиш учун:

• Истеъмолчи хабарни муваффақиятли ишлаганига ишонч ҳосил қилиш.
• Бу хабарнинг offsetини Kafkaда тасдиқлаш (commit), яъни брокерга хабарлар бу offsetгача ишланганлигини хабар бериш.

Goда, Kafka мижозидан (масалан, sarama ёки confluent-kafka-go) фойдаланиб, хабарлар ишланганидан кейин offsetларни аниқ тасдиқлаш мумкин. Агар offset тасдиқланса, хабар ўқилган деб ҳисобланади ва бу истеъмолчига яна етказилмайди.

Misol sarama билан (оддийлаштирилган):

consumer.MarkMessage(msg, "") // Хабарни ўқилган сифатида белгилаш
consumer.CommitOffsets()       // Offsetларни тасдиқлаш

Шу тариқа, хабар ўқилганлиги ҳақиқати муваффақиятли offset тасдиқлаш билан белгиланади.