如何使用java为kafka 0.10.1.x创建没有zookeeper依赖的kafka主题? 我见过创建主题的线程,但它使用了zookeeper、zk客户端等。我只想使用java来完成它,没有scala依赖,因为kafka 0.10已经不使用zookeeper。
最佳答案
是的,可以在不连接到 ZooKeeper 的情况下创建 Kafka 主题。
虽然此功能在 Kafka 0.10.1 的代理中可用,但 AdminClient(使用代理功能的客户端代码)仅在 Kafka 0.11 中添加。
参见KafkaAdminClient.createTopics()
:http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/admin/KafkaAdminClient.html#createTopics-java.util.Collection-org.apache.kafka.clients.admin.CreateTopicsOptions-
关于java - 使用java api创建Kafka主题,无需zookeeper,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47750306/