როდესაც საუბარია Kafka-ზე, რა გადაზიდვის გარანტიას უჭერთ მხარს?

Kafka-ში, შეტყობინებების მიწოდების სამი ძირითადი დონე შეიძლება უზრუნველყოფილი იყოს:

1. მაქსიმუმ ერთხელ (არაუმეტეს ერთხელ) — შეტყობინება შეიძლება მიეწოდოს 0 ან 1 ჯერ. შესაძლებელია შეტყობინებების დაკარგვა, მაგალითად, თუ მოხდა შეცდომა დადასტურებამდე.

2. მინიმუმ ერთხელ (მინიმუმ ერთხელ) — შეტყობინება გარანტირებულად მიეწოდება, მაგრამ შეიძლება მიეწოდოს რამდენიმე ჯერ (დუბლიკატები). ამას აღწევს ბროკერის დადასტურებებით და საჭიროების შემთხვევაში გადაგზავნით.

3. ზუსტად ერთხელ (მხოლოდ ერთხელ) — ყველაზე მკაცრი გარანტია, როდესაც შეტყობინება მიეწოდება და მუშავდება ზუსტად ერთხელ. Kafka-ში ეს მიღწეულია იდემპოტენტური მწარმოებლებისა და ტრანზაქციების გამოყენებით.

Go-ში Kafka-სთან მუშაობისას (მაგალითად, sarama ბიბლიოთეკის გამოყენებით), შესაძლებელია კონფიგურაცია იდემპოტენტური გაგზავნისთვის და ტრანზაქციების გამოყენებით "ზუსტად ერთხელ" გარანტიის უზრუნველსაყოფად. ჩვეულებრივ, გამოიყენება "მინიმუმ ერთხელ".

იდემპოტენტური მწარმოებლის კონფიგურაციის მაგალითი Go-ში sarama-სთან:

config := sarama.NewConfig()
config.Producer.Idempotent = true
config.Producer.RequiredAcks = sarama.WaitForAll
config.Producer.Retry.Max = 5

producer, err := sarama.NewSyncProducer(brokers, config)
if err != nil {
    panic(err)
}
// შემდეგ, გაგზავნეთ შეტყობინებები მწარმოებლის საშუალებით