カフカから消費者のリストを取得するJava API

Question

Javaアプリケーションからカフカの消費者のリストを取得することは可能ですか？現在のところ、シェルスクリプトを次のように実行しています：

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

しかし、それは間違っているようです。

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

GroupOverviewオブジェクトはあなたが必要なすべての詳細を与えるだろう：私はスカラ座から次使用したのと同じ問題に直面し、Javaに変換するものであれば、私は他の方法...

Answer 1

ませんでした開始のために。