在 Go 中使用 Shopify/sarama 库为 Kafka 主题添加 ConsumerGroup 的操作指南

“纵有疾风来，人生不言弃”，这句话送给正在学习Golang的朋友们，也希望在阅读本文《在 Go 中使用 Shopify/sarama 库为 Kafka 主题添加 ConsumerGroup 的操作指南》后，能够真的帮助到大家。我也会在后续的文章中，陆续更新Golang相关的技术文章，有好的建议欢迎大家在评论留言，非常感谢！

在 sarama 库中，有一个用于初始化 NewConsumerGroup 的选项，但如何将其挂钩到 NewConumer？

正确答案

NewConsumerGroup 创建了自己的 Consumer，因此您无需将其挂钩

来源：https://github.com/Shopify/sarama/blob/main/consumer_group.go#L105

今天关于《在 Go 中使用 Shopify/sarama 库为 Kafka 主题添加 ConsumerGroup 的操作指南》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！