Šta je consumer group u Kafka?

Grupa potrošača u Kafka je grupa potrošača koji zajedno čitaju podatke iz teme. Svaki deo teme se raspoređuje među potrošačima grupe tako da svaki deo čita samo jedan potrošač iz grupe. Ovo omogućava skaliranje obrade poruka i obezbeđuje balansiranje opterećenja. Ako u grupi ima više potrošača, oni paralelno obrađuju različite delove, a ako jedan potrošač padne, njegovi delovi se ponovo raspoređuju među preostalima.

Primer u Go koristeći biblioteku sarama:

consumerGroup, err := sarama.NewConsumerGroup(brokers, "my-group", config)
// Logika obrade poruka implementira se u handleru