Czym jest grupa konsumentów w Kafka?

Grupa konsumentów w Kafka to grupa konsumentów, którzy wspólnie odczytują dane z topiku. Każda partycja topiku jest rozdzielana pomiędzy konsumentami grupy tak, że każda partycja jest odczytywana tylko przez jednego konsumenta z grupy. Pozwala to na skalowanie przetwarzania wiadomości i zapewnienie równoważenia obciążenia. Jeśli w grupie jest kilku konsumentów, przetwarzają oni równolegle różne partycje, a jeśli jeden z nich się zawiesi, jego partycje są ponownie rozdzielane między pozostałych.

Przykład w Go z użyciem biblioteki sarama:

consumerGroup, err := sarama.NewConsumerGroup(brokers, "my-group", config)
// Logika przetwarzania wiadomości jest implementowana w obsługującym