apache-kafka - 卡夫卡流 : Internal topic partitions

Question

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

Answer 1

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

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