go - 如何在 Sarama 中使用组 ID

Question

您可能知道，Sarama 的文档非常糟糕。没有什么是清楚的。我刚刚找到了这个例子：https ://godoc.org/github.com/Shopify/sarama#example-Consumer

它消耗消息。没关系。我不知道如何在消费时使用 GroupID。

如何在 Sarama 中设置组 ID？

Answer 1

默认情况下，Sarama 不支持消费者组。

如Sarama 的常见问题解答中所述，对消费者组的支持由单独的插件提供：https ://github.com/bsm/sarama-cluster