正如您可能知道的,Sarama的文档非常糟糕。没有什么是明确的。我刚刚找到了这个例子:https://godoc.org/github.com/Shopify/sarama#example-Consumer
它使用消息。没关系。我不知道如何在消费时使用GroupID。
如何在Sarama中设置组id?
发布于 2018-06-08 23:44:51
默认情况下,Sarama不支持消费者组。
正如在Sarama's FAQ中提到的,对消费者组的支持是由一个单独的插件提供的:https://github.com/bsm/sarama-cluster
https://stackoverflow.com/questions/50760663
复制相似问题