Mi az a consumer group a Kafka-ban?

A Kafka fogyasztói csoport egy olyan fogyasztói csoport, amely közösen olvassa az adatokat egy témából. Minden téma részét a csoport fogyasztói között osztják szét úgy, hogy minden rész csak egy fogyasztó által legyen olvasva a csoportból. Ez lehetővé teszi az üzenetfeldolgozás skálázását és a terhelés kiegyensúlyozását. Ha több fogyasztó van a csoportban, párhuzamosan dolgoznak különböző részeken, és ha egy fogyasztó leáll, az ő részei újraosztásra kerülnek a többi között.

Példa Go nyelven a sarama könyvtár használatával:

consumerGroup, err := sarama.NewConsumerGroup(brokers, "my-group", config)
// Az üzenetfeldolgozási logikát a kezelő implementálja