Zookeeper：如何使用高级消费者查找 kafka 代理列表

Question

我一直在关注 high level consumer example - 但这些似乎是从 kafka 消费的。我想连接到 zookeeper (zookeperhost:2181) 并获取关联的 kafka 代理列表。有没有办法用 HLC 做到这一点？

此外，在给定 zk 的情况下，有没有办法使用 SimpleConsumer 查找 kafka 代理列表？

Answer 1

正如您在 link 中看到的那样，您没有将经纪人列表传递给 HLC，但是

props.put("zookeeper.connect", a_zookeeper);

所以它已经 linked 到 zookeeper，从那里它会发现 kafka 代理。

对于你的第二个问题，你可以选择使用 ZkClient 在 ZooKeeper 中获取 /brokers 数据，但我不会这样做，因为它取决于 Kafka 实现细节，它可能稳定也可能不稳定。