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

Question

我们应该如何从kafka集群/动物园管理员处检索所有代理（已连接/已断开连接）的完整详细信息？

我发现以下方法只获取活动代理，但我想知道以前在集群中服务的代理的IP地址，但它现在已断开连接

以下代码片段给出了活动代理的列表:

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：端口
• 我的机器-2：端口
• 我的机器-3：端口
• 我的机器-4：端口

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

Answer 1

使用管理客户端类的描述簇 （） 来获取代理详细信息，如主机、端口、ID 和岩石。

请参考以下代码:

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());
}