如何在confluent-kafka-go中创建消费者群体？

Question

由于我是Go和kafka的新手，我需要使用confluent-kafka-go模块实现消费者群体。谁能帮我吗？

提前感谢

Answer 1

使用confluent-kafka-go，您只需要在使用者配置中设置group.id，使其加入/创建组。

例如：

c, err := kafka.NewConsumer(&kafka.ConfigMap{
        "bootstrap.servers": "localhost:9092",
        "group.id":          "my-group"})

其中一个样本表明：https://github.com/confluentinc/confluent-kafka-go/blob/master/examples/consumer_example/consumer_example.go