如何从 kafka 集群中检索所有代理的详细信息

Question

我们应该如何从 kafka 集群/zookeeper 中检索所有代理（连接/断开）的完整详细信息？

我找到了以下仅获取活动代理的方法，但我想要以前在集群中服务但现在已断开连接的代理的 IP 地址

下面的代码 sn-p 给出了活跃经纪人的列表：

ZooKeeper zkInstance = new ZooKeeper("mymachine:port", 10000, null);
brokerIDs = zkInstance.getChildren("/brokers/ids", false);
for (String brokerID : brokerIDs) {
    brokerInfo = new String(zkInstance.getData("/brokers/ids/" + brokerID,     false, null));
    String     host=brokerInfo.substring(brokerInfo.indexOf("\"host\"")).split(",")    [0].replaceAll("\"","").split(":")[1];
    String     port=brokerInfo.substring(brokerInfo.indexOf("\"jmx_port\"")).split(",")    [0].replaceAll("\"","").split(":")[1];
    System.out.println(host+":"+port);              
}

输出：

• 我的机器 1：端口
• my-machine-2:端口
• my-machine-3:端口
• my-machine-4:端口

我需要多节点 kafka 集群中所有连接/断开的代理的信息

Answer 1

使用 AdminClient 类的describeCluster() 获取代理详细信息，例如host、port、id 和rock。

请参考以下代码：

Properties kafkaProperties = new Properties();
kafkaProperties.put("bootstrap.servers", "localhost:9092,localhost:9093,localhost:9094");
AdminClient adminClient = AdminClient.create(kafkaProperties);
DescribeClusterResult describeClusterResult = adminClient.describeCluster();
Collection<Node> brokerDetails = describeClusterResult.nodes().get();
System.out.println("host and port details");
for(Node broker:brokerDetails) {
    System.out.println(broker.host()+":"+broker.port());
}