如何列出所有Kafka zookeeper引導程序服務器

Question

我希望能夠以編程方式（或使用shell腳本）列出我的每個環境中的所有zookeeper引導程序服務器。

如果我只知道一個引導程序服務器，我可以得到它們全部的列表嗎？

Answer 1

所有活動經紀人都在/brokers/ids/[brokerId]下注冊，您可以通過任何ZK客戶端（例如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<<