kafka-consumer-groups.sh 等效？

【问题标题】：kafka-consumer-groups.sh equivalent?kafka-consumer-groups.sh 等效？
【发布时间】：2017-04-02 22:29:44
【问题描述】：

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

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

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

【问题讨论】：

【解决方案1】：

我认为 Java 客户端中没有等价物；我刚刚查看了那个脚本，它调用了一个 scala 类 ConsumerGroupCommand。

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

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

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

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

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

【讨论】：