apache-kafka - kafka-consumer-groups.sh 等效？

Question

我使用的是 0.10.2 版本。我想知道是否有任何 Kafka java API 可以获取偏移信息，例如使用：

./bin/kafka-consumer-groups.sh --bootstrap-server 192.168.0.28:9092 --describe --group test

因为我想在不使用 CLI 的情况下在我的应用程序中显示所有这些偏移信息。

Answer 1

我认为 Java 客户端中没有等价物。我只是看了那个脚本，它调用了一个 scala class ConsumerGroupCommand。

我不熟悉 scala，但看起来该类没有公开ZkConsumerGroupService实现命令的内部类（例如，），因此它看起来不像可以从用户应用程序调用。

看起来它无论如何都直接写入标准输出，而不是生成带有结果的对象。

我想你可以运行它并捕获标准输出......

ConsumerGroupCommand.main(new String[] {"--bootstrap-server", "localhost:9092", 
            "--describe",
            "--group", "test"});

或者，您必须从该类中提取一堆代码。