【问题标题】:Zookeeper: How to use High Level Consumer to find a find a list of kafka brokersZookeeper:如何使用 High Level Consumer 查找 kafka brokers 列表
【发布时间】:2015-06-02 23:10:24
【问题描述】:
我一直在关注high level consumer example - 但似乎这些都来自 kafka。我想连接到 zookeeper (zookeperhost:2181) 并获取相关的 kafka 代理列表。有没有办法用 HLC 做到这一点?
另外,在给定 zk 的情况下,有没有办法使用 SimpleConsumer 查找 kafka 代理列表?
【问题讨论】:
标签:
apache-zookeeper
apache-kafka
【解决方案1】:
正如您在提供的链接中看到的那样,您没有将经纪人列表传递给 HLC,但是
props.put("zookeeper.connect", a_zookeeper);
所以它已经链接到zookeeper,从那里它会发现kafka brokers。
对于第二个问题,您可以选择使用 ZkClient 在 ZooKeeper 中获取 /brokers 数据,但我不会这样做,因为它取决于 Kafka 实现细节,这可能会或可能不会稳定。