獲取卡夫卡消費者名單的Java api

Question

是否有可能從java應用程序獲取卡夫卡消費者列表？目前我只是執行shell腳本的方式如下：

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

但是這看起來不對。到目前爲止，我沒有任何其他辦法...

Answer 1

當我面對我使用階以下的同樣的問題，轉換爲Java：

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

的GroupOverview對象會給你你需要的所有細節作爲一個開始。