我们的机构有一个Zookeeper和多个独立的Kafka经纪人。我们需要通过编程在特定的代理上创建一个主题。
我们正在使用adminutils创建主题（首先检查它是否已经存在）。电话如下所示：

AdminUtils.createTopic(zkUtils, topic, partitions = 1, replicationFactor = 1, properties)

对于cleanup.policy，“properties”只有一个条目。这个调用的问题是，没有地方指定要在哪个kafka代理上创建主题，所以zookeeper随机选择一个。
如何指定应该为其创建主题的代理？