რა არის consumer group Kafka-ში?

Kafka-ში მომხმარებელთა ჯგუფი არის მომხმარებელთა ჯგუფი, რომელიც ერთობლივად კითხულობს მონაცემებს თემიდან. თითოეული თემის ნაწილი განაწილებულია ჯგუფის მომხმარებელთა შორის ისე, რომ თითოეული ნაწილი იკითხება მხოლოდ ერთ მომხმარებელზე ჯგუფში. ეს საშუალებას აძლევს შეტყობინებების დამუშავების მასშტაბირებას და დატვირთვის ბალანსს. თუ ჯგუფში რამდენიმე მომხმარებელია, ისინი პარალელურად processing სხვადასხვა ნაწილებს, ხოლო თუ ერთი მომხმარებელი ჩავარდება, მისი ნაწილები გადანაწილდება დარჩენილებზე.

მაგალითი Go-ში, sarama ბიბლიოთეკის გამოყენებით:

consumerGroup, err := sarama.NewConsumerGroup(brokers, "my-group", config)
// შეტყობინებების დამუშავების ლოგიკა იმპლემენტირებულია handler-ში