2016-11-18 2 views

답변

4

당신은 /브로커/IDS에서 브로커 IDS 반복하고 이러한 IDS에서 브로커 정보를 가져 오는에 의해 사육사를 통해 브로커 목록을 얻을 수 있습니다

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); 
} 
+0

참고 :이 방법은, 하위에 대한 지원을 이전 클라이언트에 대한 호환성을 제공하며 SASL_SSL과 같은 보안 기능이 구성된 서버에서는 작동하지 않습니다. https://issues.apache.org/jira/browse/KAFKA-3948을 참조하십시오. 새로운 접근법은 호스트 이름과 포트 번호를 포함하는 끝점을 구문 분석하고 처리하는 것입니다. "끝점": [ "SASL_SSL : // kafka01 : 9093"] 및 "끝점": [ "PLAINTEXT : //127.0.0.1 : 9092"], – JulianHarty