【问题标题】:How to create Kafka Partitions using Java Code如何使用 Java 代码创建 Kafka 分区
【发布时间】:2018-05-21 18:40:15
【问题描述】:

我正在尝试使用 JAVA 创建 Kafka 分区但没有成功。

谁能给我一些例子,如何使用 Java 代码在 kafka 中创建分区。

【问题讨论】:

    标签: java apache-kafka


    【解决方案1】:

    你的意思不是很清楚。如果您尝试增加现有主题的分区数,使用的方法是 AdminClient.createPartitions

    如果主题尚不存在,您可以使用 AdminClient.createTopics,它将分区计数作为NewTopic 对象中的字段。

    【讨论】:

    • :- 我的主题还不存在。我正在尝试通过 java 代码创建带有分区的新主题。
    猜你喜欢
    • 2018-11-29
    • 2013-08-16
    • 2015-11-29
    • 1970-01-01
    • 2020-06-03
    • 1970-01-01
    • 2020-12-27
    • 1970-01-01
    • 2017-07-31
    相关资源
    最近更新 更多