【发布时间】:2018-05-21 18:40:15
【问题描述】:
我正在尝试使用 JAVA 创建 Kafka 分区。但没有成功。
谁能给我一些例子,如何使用 Java 代码在 kafka 中创建分区。
【问题讨论】:
标签: java apache-kafka
我正在尝试使用 JAVA 创建 Kafka 分区。但没有成功。
谁能给我一些例子,如何使用 Java 代码在 kafka 中创建分区。
【问题讨论】:
标签: java apache-kafka
你的意思不是很清楚。如果您尝试增加现有主题的分区数,使用的方法是 AdminClient.createPartitions。
如果主题尚不存在,您可以使用 AdminClient.createTopics,它将分区计数作为NewTopic 对象中的字段。
【讨论】: