如何在Golang中创建kafka消费者组？

消费方组由集群消费方“构造函数”的第二个参数指定。这是一个非常基本的草图：

import (    "github.com/Shopify/sarama"    "github.com/bsm/sarama-cluster")conf := cluster.NewConfig()// add config valuesbrokers := []string{"kafka-1:9092", "kafka-2:9092"}group := "Your-Consumer-Group"topics := []string{"topicName"}consumer := cluster.NewConsumer(broker, group, topics, conf)

因此，您将拥有一个属于指定消费者组的消费者。