可用的库是sarama（或其扩展sarama- cluster），但是没有提供消费者群体示例，在sarama或sarama-cluster中均未提供。
我不了解API。我可以举一个为主题创建消费者组的示例吗？
消费方组由集群消费方“构造函数”的第二个参数指定。这是一个非常基本的草图：
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 := []string{"topicName"} consumer := cluster.NewConsumer(broker, group, topics, conf)
因此，您将拥有一个属于指定消费者组的消费者。
