apache-kafka - 从 Kafka 客户端增加 Kafka 主题中的分区数

Question

我是 Apache Kafka 的新用户，我仍在了解内部结构。

在我的用例中，我需要从 Kafka Producer 客户端动态增加主题的分区数。

我发现了其他类似的 questions关于增加分区大小，但他们使用了动物园管理员配置。但是我的 kafkaProducer 只有 Kafka broker 配置，但没有 zookeeper 配置。

有什么方法可以从生产者端增加主题的分区数吗？我正在运行 Kafka 版本 0.10.0.0。

Answer 1

从 Kafka 0.10.0.1(最新版本)开始:正如 Manav 所说，不可能从 Producer 增加分区数客户。

展望 future (下一个版本):在即将发布的 Kafka 版本中，客户端将能够执行一些主题管理操作，如 KIP-4 中所述。 .许多 KIP-4 功能已经在 Kafka 的 trunk 中完成并可用。 ; trunk中的代码截至今天，允许客户创建和删除主题。但不幸的是，对于您的用例，仍然无法增加分区数量——这在 KIP-4 的范围内(参见 Alter Topics Request)，但尚未完成。

TL;DR:下一版本的 Kafka 将允许您增加 Kafka 主题的分区数量，但此功能尚不可用。