java 通过kafkaadmin获取kafka集群指标信息
时间: 2023-11-11 19:00:45 浏览: 55
可以通过 KafkaAdminClient 来获取 Kafka 集群的指标信息。具体步骤如下:
1. 创建 KafkaAdminClient 对象:
```
Properties props = new Properties();
props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
KafkaAdminClient adminClient = (KafkaAdminClient) KafkaAdminClient.create(props);
```
2. 使用 KafkaAdminClient 获取指标信息:
```
DescribeClusterResult describeClusterResult = adminClient.describeCluster();
Cluster cluster = describeClusterResult.cluster().get();
System.out.println("Cluster id: " + cluster.clusterId());
System.out.println("Controller: " + cluster.controller());
System.out.println("Nodes: " + cluster.nodes());
```
其中,`describeCluster()` 方法返回一个 `DescribeClusterResult` 对象,通过该对象可以获取到 Kafka 集群的各种信息,比如集群 ID、Controller、节点等。