由于我是Go和kafka的新手,因此我需要使用confluent-kafka-go模块实现消费者群体。谁能帮我吗?
预先感谢
由于我是Go和kafka的新手,因此我需要使用confluent-kafka-go模块实现消费者群体。谁能帮我吗?
预先感谢
使用confluent-kafka-go
,您只需在使用者配置中设置group.id
,即可加入/创建组。
例如:
c,err := kafka.NewConsumer(&kafka.ConfigMap{
"bootstrap.servers": "localhost:9092","group.id": "my-group"})