go - kafka sarama lib如何知道一个cosumergroup中有多少cosumer

Question

我在这里阅读了消费者组示例（由 Shopify/sarama 提供），我想知道我如何知道一个消费者组中有多少消费者，有什么方法可以控制消费者的数量吗？

非常感谢

Answer 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