【发布时间】:2018-05-24 19:42:48
【问题描述】:
如何使用 java 为 kafka 0.10.1.x 创建不依赖 zookeeper 的 kafka 主题? 我已经看到创建主题的线程,但它使用了 zookeeper、zk 客户端等。我只想使用 java 来完成,没有 scala 依赖项,因为 kafka 0.10 已经没有使用 zookeeper。
【问题讨论】:
标签: java apache-kafka
如何使用 java 为 kafka 0.10.1.x 创建不依赖 zookeeper 的 kafka 主题? 我已经看到创建主题的线程,但它使用了 zookeeper、zk 客户端等。我只想使用 java 来完成,没有 scala 依赖项,因为 kafka 0.10 已经没有使用 zookeeper。
【问题讨论】:
标签: java apache-kafka
从 0.11.0.0 开始,该功能在客户端可用,新的 Admin Client API 将取代旧的 API。 你可以在这里找到一个使用它的简单例子:https://github.com/ppatierno/kafka-playground/blob/master/src/main/java/org/apache/kafka/playground/CreateTopic.java
【讨论】:
是的,可以在不连接 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-
【讨论】: