Kafka Streams：内部主题分区

Question

卡夫卡版本：1.0.0
假设流应用程序使用低级处理器 API 来维护状态并从具有 10 个分区的主题中读取。请说明内部主题是否应该使用相同数量的分区创建，或者是根据代理默认设置创建的。如果是后者，如果我们需要增加内部主题的分区，有没有选择？

Answer 1

Kafka Streams 将为您创建主题。是的，它将使用与您的输入主题相同数量的分区创建它。在启动期间，Kafka Streams 还会检查主题是否具有预期的分区数，如果没有则失败。

内部主题基本上和其他任何主题一样都是常规主题，您可以像任何其他主题一样通过命令行工具更改分区数。但是，这绝不是必需的。另请注意，dropping/adding 个分区会扰乱您的状态。