以编程方式（JAVA）从 Kafka 主题创建/删除分区

Question

按需运行时，我可以通过编程方式（使用 java）从 Kafka 主题创建/删除分区

我正在使用 Java Apache Kafka 客户端 (0.10) 和 Apache Kafka 安装 (0.10)

Answer 1

调用 AdminUtils.createTopic 和 AdminUtils.deleteTopic 分别创建和删除主题。

编辑：

使用 AdminUtils.addPartitions 为主题添加分区。 Kafka 目前不支持减少分区数。