0
我們的設置有一個Zookeeper和多個獨立的卡夫卡經紀人。我們需要以編程方式在特定經紀商上創建主題。One Zookeeper，多個Kafka經紀人 - 如何以編程方式在特定經紀商上創建主題？
我們使用AdminUtils來創建主題（在檢查它是否已經存在之後）。該調用如下所示：
AdminUtils.createTopic(zkUtils, topic, partitions = 1, replicationFactor = 1, properties)
「屬性」只有一個條目，用於cleanup.policy。這次電話會議的問題在於，無法指定我們想要創建哪個主題的卡夫卡經紀人，因此Zookeeper會選擇一個並隨機選擇。
如何指定要爲其創建主題的代理？
有該主題可以創建到特定代理沒有這樣的概念。此外，Properties類擴展了Hashtable，它提供了'setProperty'方法，允許用戶將多個KV對連接到它。 – amethystic
換句話說，如果我想分離經紀人，他們都必須與一個不同的Zookeeper實例關聯？這聽起來不對...... –