如何使用Java API列出Kafka集群中所有可用的代理

Question

标题是怎么说的。

是否有(使用Kafka Java API(获取集群中可用Kafka代理的数量？

我知道，使用Kafka服务器附带的命令行实用程序，这是可以做到的；但是我还没有找到任何关于如何使用Java API来实现它的东西。

Answer 1

您可以从kafkaAdminClient.descripteCluster 获取代理和集群信息

使用默认选项获取集群中节点的信息。这是#describeCluster(DescribeClusterOptions(的一种方便方法，具有默认选项。有关更多详细信息，请参阅过载。

Properties properties = new Properties();
properties.setProperty("bootstrap.servers", "localhost:9092");
properties.setProperty("client.id", "producerAdmin");
properties.setProperty("metadata.max.age.ms", "3000");
kafkaAdminClient = AdminClient.create(properties);
DescribeClusterResult result = kafkaAdminClient.describeCluster()
KafkaFuture<Collection<Node>> nodes = result.nodes();

您可以使用Node类中的主机、端口方法来获取更多信息