英文:
How to add consumerGroup for a topic in kafka using Shopify/sarama golang library?
问题
在sarama库中,有一个选项可以初始化NewConsumerGroup,但如何将其与NewConsumer连接起来?
英文:
In the sarama library there is an option to initialize NewConsumerGroup but how to hook it hook i t up to NewConumer?
答案1
得分: 1
NewConsumerGroup
会创建自己的Consumer,所以你没有什么可以连接的。
英文:
NewConsumerGroup
creates its own Consumer, so there's nothing for you to hook it to
Source: https://github.com/Shopify/sarama/blob/main/consumer_group.go#L105
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库,让每个人都能够通过互相帮助和分享经验来进步。
评论