სად ინახება Kafka-ს შიგნით მოხმარებული შეტყობინებების Offset მნიშვნელობა?

Apache Kafka-ში, მოხმარებული შეტყობინებების Offset მნიშვნელობა ინახება სპეციალურ შიდა თემაში სახელწოდებით __consumer_offsets. ეს თემა ინახავს ინფორმაციას თითოეული მომხმარებლის (consumer group) მიმდინარე პოზიციაზე თითოეულ ნაწილში (partition) თემის.

ამ გზით, Kafka არ ინახავს offset-ებს ადგილობრივად მომხმარებელთან, არამედ ცენტრალიზებულად კლასტერში, რაც საშუალებას აძლევს მომხმარებლებს განახლდნენ და განაგრძონ კითხვა საჭირო პოზიციიდან.

გარდა ამისა, მომხმარებლები შეიძლება ხელით (commit) ან ავტომატურად ინახავდნენ offset-ებს, დამოკიდებულია მომხმარებლის კონფიგურაციაზე.

მაგალითი Go-ში, confluent-kafka-go ბიბლიოთეკის გამოყენებით offset-ების commit-ის:

consumer.CommitMessage(message)

სადაც message არის წაკითხული შეტყობინება, რომლის offset-იც ინახება.