【发布时间】:2022-01-20 23:06:36
【问题描述】:
在 sarama 库中,有一个初始化 NewConsumerGroup 的选项,但是如何将它与 NewConumer 挂钩?
【问题讨论】:
标签: go apache-kafka kafka-consumer-api sarama
在 sarama 库中,有一个初始化 NewConsumerGroup 的选项,但是如何将它与 NewConumer 挂钩?
【问题讨论】:
标签: go apache-kafka kafka-consumer-api sarama
NewConsumerGroup 创建自己的消费者,所以你没有什么可以挂钩的
来源:https://github.com/Shopify/sarama/blob/main/consumer_group.go#L105
【讨论】: