在sarama中如何使用组id

vs3odd8k  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(644)

你可能知道,萨拉玛的文件很糟糕。什么都不清楚。我刚刚发现了这个例子:https://godoc.org/github.com/shopify/sarama#example-消费者
它消耗消息。没关系。我不知道在消费时如何使用groupid。
如何在sarama中设置组id?

y3bcpkx1

y3bcpkx11#

默认情况下,sarama不支持消费群体。
正如sarama的faq中提到的,对消费者群体的支持是由一个单独的插件提供的:https://github.com/bsm/sarama-cluster

相关问题