java - 如何使用 Java 代码创建 Kafka 分区

Question

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

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

标签： javaapache-kafka

Answer 1

你的意思不是很清楚。如果您尝试增加现有主题的分区数量，则使用的方法是 AdminClient。创建分区。

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