Java api 从 Kafka 获取消费者列表

Question

是否可以从 java 应用程序中获取来自 Kafka 的消费者列表？目前我只是按照以下方式执行 shell 脚本：

Runtime.getRuntime().exec(/opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list)

不过好像不对。到目前为止我没有任何其他方式...

Answer 1

当我遇到同样的问题时，我使用了 scala 中的以下内容并转换为 Java:

scala.collection.immutable.List<GroupOverview> consumerList = getAdminClient().listAllConsumerGroupsFlattened();

GroupOverview 对象将为您提供开始所需的所有详细信息。