【问题标题】:Kafka topic creation using java api without zookeeper使用没有 zookeeper 的 java api 创建 Kafka 主题
【发布时间】: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


    【解决方案1】:

    从 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

    【讨论】:

    • 是的,我试图保持对 0.10 版本身的 maven 依赖。更高版本是可能的。谢谢。
    【解决方案2】:

    是的,可以在不连接 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-

    【讨论】:

    • 是的,我试图保持 maven 对 0.10 版本身的依赖。更高版本是可能的。谢谢。
    猜你喜欢
    • 2018-01-07
    • 1970-01-01
    • 1970-01-01
    • 2018-03-31
    • 2019-12-20
    • 2021-10-27
    • 2016-07-21
    • 2015-08-10
    • 2019-05-18
    相关资源
    最近更新 更多