Kas ir consumer group Kafka?

Kafka patērētāju grupa ir patērētāju grupa, kas kopīgi lasa datus no tēmas. Katra tēmas daļa tiek sadalīta starp grupas patērētājiem tā, lai katra daļa tiktu lasīta tikai ar vienu patērētāju no grupas. Tas ļauj mērogot ziņojumu apstrādi un nodrošināt slodzes līdzsvaru. Ja grupā ir vairāki patērētāji, tie paralēli apstrādā dažādas daļas, un ja viens patērētājs neizdodas, tā daļas tiek pārredistribuētas starp pārējiem.

Piemērs Go valodā, izmantojot sarama bibliotēku:

consumerGroup, err := sarama.NewConsumerGroup(brokers, "my-group", config)
// Ziņojumu apstrādes loģika tiek īstenota handlerī