すべてのKafka zookeeperブートストラップサーバーを一覧表示する方法

Question

各環境ですべてのzookeeperブートストラップサーバーを一覧表示するには、プログラムで（シェルスクリプトを使用する）できます。

もし私がブートストラップサーバーのどれかを知っていれば、それらのすべてのリストを得ることができますか？

Answer 1

すべてのアクティブなブローカーは/brokers/ids/[brokerId]の下に登録されています.ZNクライアント（例：org.I0Itec.zkclient）からZNode情報を問い合わせることができます。 zkQuorumアドレスだけが必要です。

zkClient = new ZkClient(properties.getProperty("zkQuorum"), zkSessionTimeout, zkConnectionTimeout, 
       ZKStringSerializer$.MODULE$); 

Kafka data structures in Zookeeper

Answer 2

わからないこれは直接に役立ちますが、私はカフカの飼育係からブートストラップサーバを検索するには、以下の使用している場合：

zkCli.sh -server host:port 
[zkCli prompt] ls /kafka 
[..., brokers, ...] 
[zkCli prompt] ls /kafka/brokers 
[1, 2, 3, 4, 5] 
[zkCli prompt] ls /kafka/brokers/1 
[1] 
[zkCli prompt] get /kafka/brokers/1 
>> broker info<<