【问题标题】:kafka sarama lib how to know how many cosumers in a cosumergroupkafka sarama lib如何知道一个消费者组中有多少消费者
【发布时间】:2020-01-05 13:40:50
【问题描述】:

我阅读了here(Shopify/sarama 提供)中的消费者组示例, 我想知道我怎么知道一个消费者群体中有多少消费者,有什么方法可以控制消费者的数量吗?

非常感谢

【问题讨论】:

    标签: go apache-kafka sarama


    【解决方案1】:

    要列出当前分配给某个组的消费者,您可以使用 kafka-consumer-groups .sh shell 脚本。假设 $KAFKA_HOME 是你的 Kafka 安装的根目录,你可以这样做:

    $KAFKA_HOME/bin/kafka-consumer-groups.sh --describe --group YOURGROUP --zookeeper ZOOKEEPER_HOST:PORT
    

    如果要列出当前组,请运行以下命令:

    $KAFKA_HOME/bin/kafka-consumer-groups.sh --list --zookeeper ZOOKEEPER_HOST:PORT
    

    【讨论】:

    • 谢谢。但我想知道我可以列出它或使用 sarama 增加/减少消费者吗?
    • 也许你可以看看 sarama/consumer_group_members.go (github.com/Shopify/sarama/blob/master/consumer_group_members.go)
    • 非常感谢,我去看看。
    • 请问不应该是--bootstrap-server 而不是--zookeeper(我认为它是用在消费者而不是消费者组中)?
    • 是的,你对自 Kafka 0.9 以来的新消费者 API 是正确的。您可以访问此链接以获取有关新旧消费者 API 的更多信息:pavelmakhov.com/2017/03/useful-kafka-commands
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2020-09-19
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多