カフカプロデューサーは、どのように動物園の利用可能なブローカーを知っていますか？

Question

私は3ノードカフカクラスターをセットアップしました。私はプロデューサークライアントのために利用可能なブローカーを知りたい。飼い主に接続しているブローカーを一覧表示するコマンドはありますか？

Answer 1

あなたは/ブローカー/ IDSでブローカーのIDを反復して、これらのIDからブローカーの情報を取得することでのZooKeeperを経由してブローカーのリストを取得することができます。

ZooKeeper zk = new ZooKeeper("localhost:2181", 10000, null); 
List<String> ids = zk.getChildren("/brokers/ids", false); 

for (String id : ids) { 
    String brokerInfo = new String(zk.getData("/brokers/ids/" + id, false, null)); 
    System.out.println(id + ": " + brokerInfo); 
}