java - 如何从 Java 中的 Kafka 服务器（不是 Zookeeper）获取所有 ConsumerGroup 的列表

Question

Kafka 中是否有任何 Java Api 可以为我提供所有消费者组的列表以及他们正在消费的主题/分区此外，有没有什么方法可以从 kafka 服务器端获取 zookeeper 列表。注意：我可以从 Zookeeper 获取上述信息。但我想从 Kafka Server 获取它。你能帮我解决这个问题吗！！

提前致谢！！

Answer 1

你可以使用kafka-consumer-groups.sh命令。这将列出消费者组。

./kafka-consumer-groups.sh --list --bootstrap-server localhost:9092

打开该脚本时，您将看到以下内容。

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
    export KAFKA_HEAP_OPTS="-Xmx512M"
fi

exec $(dirname $0)/kafka-run-class.sh kafka.tools.ConsoleConsumer "$@"

对于窗户，

"%~dp0kafka-run-class.bat" kafka.admin.ConsumerGroupCommand %*

在 Github 中，您可以看到ConsumerGroupCommand的代码。

我想，你可以使用那些 API。

附言

我不知道你的另一个问题：

另外，有什么方法可以从kafka服务器端获取zookeeper列表

（我认为不，也许吧？）