如何在confluent-kafka-go中创建具有多个消费者的消费者群体?

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

预先感谢

song0007 回答:如何在confluent-kafka-go中创建具有多个消费者的消费者群体?

使用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

本文链接:https://www.f2er.com/3124389.html

大家都在问