获取有关Kafka连接集群的信息

要获取有关Kafka连接集群的信息，可以使用Kafka提供的Java客户端库来实现。下面是一个示例代码，演示如何获取Kafka连接集群的信息：

import kafka.utils.ZkUtils;
import scala.collection.Seq;

public class KafkaClusterInfo {
    public static void main(String[] args) {
        // 设置Zookeeper连接字符串和会话超时时间
        String zkConnect = "localhost:2181";
        int sessionTimeoutMs = 10000;

        // 创建ZkUtils对象
        ZkUtils zkUtils = ZkUtils.apply(zkConnect, sessionTimeoutMs, sessionTimeoutMs, false);

        try {
            // 获取所有的Kafka broker ID
            Seq<String> brokerIds = zkUtils.getAllBrokersInCluster();

            // 打印每个broker的信息
            for (String brokerId : scala.collection.JavaConversions.seqAsJavaList(brokerIds)) {
                // 获取broker的host和port
                String brokerHost = zkUtils.getBrokerInfo(Integer.parseInt(brokerId)).get().getBrokerEndPoint().host();
                int brokerPort = zkUtils.getBrokerInfo(Integer.parseInt(brokerId)).get().getBrokerEndPoint().port();

                System.out.println("Broker ID: " + brokerId);
                System.out.println("Broker Host: " + brokerHost);
                System.out.println("Broker Port: " + brokerPort);
                System.out.println();
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭ZkUtils对象
            zkUtils.close();
        }
    }
}

在上述代码中，我们使用了Kafka的ZkUtils类来连接到Zookeeper，并获取了所有Kafka broker的信息，包括broker的ID、host和port。可以根据实际情况修改zkConnect变量来指定正确的Zookeeper连接字符串。