動物園管理員：如何使用高級消費者找到一個卡夫卡經紀人名單

Question

我一直在關注high level consumer example - 但它似乎是從卡夫卡消費。我想連接到zookeeper（zookeperhost：2181）並獲取關聯的kafka代理列表。有沒有辦法用HLC來做到這一點？

此外，有沒有一種方法可以使用SimpleConsumer查找kafka代理列表，給定zk？

Answer 1

正如你可以在你給的鏈接看到，你不通過經紀人列表中HLC，但

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

所以它已經連接到動物園管理員，並從那裏就會發現卡夫卡經紀人。

對於第二個問題，您可以選擇使用ZkClient獲取/代理ZooKeeper中的數據，但我不這樣做，因爲它取決於Kafka實現細節，這可能會也可能不穩定。