broker 信息获取

kafka-01/kafka-01-producer/src/test/java/cn/skcks/study/springcloud/kafka/tests/KafkaConfigTest.java

@@ -52,6 +52,18 @@ public class KafkaConfigTest {
         return AdminClient.create(kafkaProperties.buildAdminProperties());
     }
 
+    @Test
+    @SneakyThrows
+    void clusterInfo(){
+        try(AdminClient client = adminClient()){
+            DescribeClusterResult result = client.describeCluster();
+            log.info("kafka 集群信息");
+            result.nodes().get().forEach(broker -> {
+                log.info("broker id => {}, Addr => {}:{}",broker.id(),broker.host(),broker.port());
+            });
+        }
+    }
+
     @Test
     @SneakyThrows
     void topics() {