【问题标题】:How to add consumerGroup for a topic in kafka using Shopify/sarama golang library?如何使用 Shopify/sarama golang 库为 kafka 中的主题添加 consumerGroup?
【发布时间】:2022-01-20 23:06:36
【问题描述】:

在 sarama 库中,有一个初始化 NewConsumerGroup 的选项,但是如何将它与 NewConumer 挂钩?

【问题讨论】:

    标签: go apache-kafka kafka-consumer-api sarama


    【解决方案1】:

    NewConsumerGroup 创建自己的消费者,所以你没有什么可以挂钩的

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多