重新部署后Kafka Streams报内部主题分区无效是什么原因？

• Kafka Streams内部状态存储对应的changelog topic分区数由拓扑逻辑决定，和NUM_STREAM_THREADS_CONFIG配置的流线程数没有关联：这类changelog的分区数必须和其绑定的上游算子（你场景中是suppress对应的KTable）的输入分区数完全一致，报错信息里的预期10个分区就是你上游输入topic的实际分区数。
• 出现实际分区数为1的核心诱因：你首次将线程数调整到50启动应用的过程中，my-app-KTABLE-SUPPRESS-STATE-STORE-0000000015-changelog这个topic要么被意外手动删除，要么Streams自动创建topic的请求超时/失败，之后因为集群开启了auto.create.topics.enable配置，当有数据需要写入这个topic时，Kafka按照集群默认的num.partitions=1配置自动创建了该topic，导致分区数不符合拓扑要求。
• 改回线程数10也无法恢复的原因：Streams每次启动都会强制校验所有内部topic的元数据是否符合拓扑预期，校验失败就会直接抛出错误退出，这个校验逻辑和流线程数配置无关，只要changelog分区数不匹配就会报错。

如果你可以接受该suppress状态存储中当前缓存的未下发数据丢失，可执行以下操作：

1. 停止所有该应用的运行实例
2. 手动删除异常的changelog topic：kafka-topics.sh --bootstrap-server <broker地址> --delete --topic my-app-KTABLE-SUPPRESS-STATE-STORE-0000000015-changelog
3. 重启应用，Kafka Streams会自动按照拓扑要求的10个分区重新创建该changelog topic，应用会从最近的消费位点继续处理，仅丢失该suppress算子的现有状态数据，不需要从头重处理全量数据。

内容的提问来源于stack exchange，提问作者Paul C