0
我们的设置有一个Zookeeper和多个独立的卡夫卡经纪人。我们需要以编程方式在特定经纪商上创建主题。One Zookeeper，多个Kafka经纪人 - 如何以编程方式在特定经纪商上创建主题？
我们使用AdminUtils来创建主题（在检查它是否已经存在之后）。该调用如下所示：
AdminUtils.createTopic(zkUtils, topic, partitions = 1, replicationFactor = 1, properties)
“属性”只有一个条目，用于cleanup.policy。这次电话会议的问题在于，无法指定我们想要创建哪个主题的卡夫卡经纪人，因此Zookeeper会选择一个并随机选择。
如何指定要为其创建主题的代理？
有该主题可以创建到特定代理没有这样的概念。此外，Properties类扩展了Hashtable，它提供了'setProperty'方法，允许用户将多个KV对连接到它。 – amethystic
换句话说，如果我想分离经纪人，他们都必须与一个不同的Zookeeper实例关联？这听起来不对...... –