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

Question

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

提前致谢!!

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 "$@"

对于 Windows，

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

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

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

附注

我不知道你的其他问题:

Also, is there any way that I can fetch the zookeeper list from the kafka server side

(我想不是，也许吧？)