如何使用Shopify/sarama Golang库在Kafka中为主题添加消费者组?

huangapple go评论101阅读模式
英文:

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

huangapple
  • 本文由 发表于 2022年1月20日 16:04:39
  • 转载请务必保留本文链接:https://go.coder-hub.com/70782622.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定