Kafka制作人如何知道zookeeper提供哪些经纪人？

nkoocmlb 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(286)

我已经建立了一个3节点的Kafka集群。我想知道哪些经纪人可以为制片人客户服务。有没有命令列出与Zookeeper相连的经纪人？

apache-kafka apache-zookeeper kafka-producer-api

来源：https://stackoverflow.com/questions/40683786/how-does-a-kafka-producer-know-which-are-the-available-brokers-from-zookeeper

1条答案

按热度按时间

5kgi1eie1#

您可以通过zookeeper获取代理列表，方法是迭代/brokers/ids中的代理ID，然后从这些ID获取代理信息：

ZooKeeper zk = new ZooKeeper("localhost:2181", 10000, null);
List<String> ids = zk.getChildren("/brokers/ids", false);

for (String id : ids) {
   String brokerInfo = new String(zk.getData("/brokers/ids/" + id, false, null));
   System.out.println(id + ": " + brokerInfo);
}

赞(0）回复(0）举报 2021-06-07

我来回答

Kafka制作人如何知道zookeeper提供哪些经纪人？

1条答案

相关问题

热门标签

最新问答