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

Apache Kafka-ში შეტყობინებების დამუშავების დადასტურება (acknowledgment) ხორციელდება offset commit მექანიზმის საშუალებით.

პროცესი:

1. მომხმარებელი იღებს შეტყობინებას თემიდან.
2. წარმატებული დამუშავების შემდეგ, მომხმარებელი ამ შეტყობინების offset-ს ინახავს (commit-ს აკეთებს).
3. Kafka ინახავს ინფორმაციას ბოლო დადასტურებული offset-ის შესახებ თითოეული მომხმარებლის ჯგუფისთვის.

Go-ში, Kafka-ის მომხმარებლის (მაგალითად, sarama ან confluent-kafka-go) გამოყენებით, დადასტურება შეიძლება იყოს ავტომატური ან ხელით:

• ავტომატური commit — მომხმარებელი პერიოდულად აგზავნის ინფორმაციას ბოლო დამუშავებული offset-ის შესახებ.
• ხელით commit — პროგრამისტი პირდაპირ ახორციელებს commit მეთოდს შეტყობინების დამუშავების შემდეგ, რაც უზრუნველყოფს მეტ კონტროლსა და საიმედოობას.

მაგალითი sarama-სთან (ხელით commit):

consumer, _ := sarama.NewConsumerGroup(brokers, groupID, config)
// შეტყობინებების handler-ში, დამუშავების შემდეგ:
session.MarkMessage(message, "") // აღნიშნავს შეტყობინებას როგორც დამუშავებულს
// დამუშავების დასრულების შემდეგ, გამოიძახება Commit()