你可能知道,萨拉玛的文件很糟糕。什么都不清楚。我刚刚发现了这个例子:https://godoc.org/github.com/shopify/sarama#example-消费者它消耗消息。没关系。我不知道在消费时如何使用groupid。如何在sarama中设置组id?
y3bcpkx11#
默认情况下,sarama不支持消费群体。正如sarama的faq中提到的,对消费者群体的支持是由一个单独的插件提供的:https://github.com/bsm/sarama-cluster
1条答案
按热度按时间y3bcpkx11#
默认情况下,sarama不支持消费群体。
正如sarama的faq中提到的,对消费者群体的支持是由一个单独的插件提供的:https://github.com/bsm/sarama-cluster