我怎樣才能得到所有組列表與kafka0.10.x

當我使用kafka0.8.x，我可以通過路徑「/ consumers/group_id」得到所有組的動物園管理員名單，因爲偏移量將在0.8中提交給動物園管理員。X。我怎樣才能得到所有組列表與kafka0.10.x

但是在版本0.10.x中，抵消承諾給kafka代理，如路徑「/ brokers/topics/__customer_offsets」和路徑「/ consumers」在zookeeper中沒有任何內容。所以我無法通過zookeeper獲得消費者組列表。

來源

2017-01-16 wxmimperio

要列出所有話題所有消費羣體：

斌/ kafka-consumer-groups.sh --bootstrap服務器BROKER1：對於9092 --list

要查看偏移消費羣：

斌/ kafka-consumer-groups.sh --bootstrap服務器BROKER1：9092 --describe --group測試消費羣體

有關詳細信息，請參見Managing Consumer Groups。

來源

2017-01-16 09:27:52 amethystic

是的，它可以使用shell命令來獲取組列表。但通過API獲取組信息的任何其他方式？當我從zookeeper獲得組列表時，我可以獲取節點信息來顯示組創建時間，更新時間，這個組中有多少用戶......有很多我可以從zookeeper獲得的信息，但是當偏移提交給經紀人的信息比以前少，我想知道小組和消費者的結構，有沒有文件可以提供？ – wxmimperio

好吧，沒有提供關於如何以編程方式獲取這些數據的詳細信息的官方文檔，但您可以嘗試AdminClient.describeGroup或AdminClient.describeConsumerGroup，它們都接收組ID作爲唯一參數。返回類型分別是GroupSummary和List [GroupSummary]。 GroupSummary封裝了大部分您想要的信息。 – amethystic

我怎樣才能得到所有組列表與kafka0.10.x

回答

相關問題