Как создать группу потребителей kafka в Голанге?

Question

Доступная библиотека: sarama (или ее расширение sarama-cluster), однако пример группы потребителей не предоставляется, а не в sarama и не в sarama-cluster.

Я не понимаю API. Могу ли я привести пример создания группы пользователей для темы?

Answer 1

Группа потребителей определяется вторым аргументом «конструктора» потребителя кластера. Вот очень простой эскиз:

import (
    "github.com/Shopify/sarama" 
    "github.com/bsm/sarama-cluster" 
) 

conf := cluster.NewConfig() 
// add config values 

brokers := []string{"kafka-1:9092", "kafka-2:9092"} 
group := "Your-Consumer-Group" 
topics := []{"topicName"} 
consumer := cluster.NewConsumer(broker, group, topics, conf) 

И поэтому у вас будет потребитель, принадлежащий к указанной группе потребителей.