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

Answer 2

您可以在 Sarama 库中使用ClusterAdmin界面。

https://pkg.go.dev/github.com/Shopify/sarama#ClusterAdmin