1
3 개 노드 카프카 클러스터를 설정했습니다. 나는 프로듀서 클라이언트에서 사용할 수있는 중개인이 누구인지 알고 싶습니다. 사육사와 연결된 중개인을 나열하는 명령이 있습니까?카프카 제작자는 사육사가 제공하는 중개인을 어떻게 알 수 있습니까?
3 개 노드 카프카 클러스터를 설정했습니다. 나는 프로듀서 클라이언트에서 사용할 수있는 중개인이 누구인지 알고 싶습니다. 사육사와 연결된 중개인을 나열하는 명령이 있습니까?카프카 제작자는 사육사가 제공하는 중개인을 어떻게 알 수 있습니까?
당신은 /브로커/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);
}
참고 :이 방법은, 하위에 대한 지원을 이전 클라이언트에 대한 호환성을 제공하며 SASL_SSL과 같은 보안 기능이 구성된 서버에서는 작동하지 않습니다. https://issues.apache.org/jira/browse/KAFKA-3948을 참조하십시오. 새로운 접근법은 호스트 이름과 포트 번호를 포함하는 끝점을 구문 분석하고 처리하는 것입니다. "끝점": [ "SASL_SSL : // kafka01 : 9093"] 및 "끝점": [ "PLAINTEXT : //127.0.0.1 : 9092"], – JulianHarty