Kafkaда consumer group деген эмне?

Kafkaда керектөөчү групп — бул биргелешип маалымат окуган керектөөчүлөрдүн тобу. Топтун ар бир бөлүгү топтогу керектөөчүлөргө бөлүнөт, ошондуктан ар бир бөлүк гана топтогу бир керектөөчү тарабынан окулат. Бул билдирүүлөрдү иштетүүнү масштабдоого жана жүктү тең салмакта кармоого мүмкүндүк берет. Эгер топто бир нече керектөөчү болсо, алар ар башка бөлүктөрдү параллел иштетишет, жана эгер бир керектөөчү иштен чыкса, анын бөлүктөрү калган керектөөчүлөргө кайра бөлүштүрүлөт.

Go тилинде sarama китепканасын колдонуу менен мисал:

consumerGroup, err := sarama.NewConsumerGroup(brokers, "my-group", config)
// Мессеждерди иштетүү логикасы иштетүүчүдө ишке ашырылат