小编Nar*_*123的帖子

我有一个应用程序，其中使用 Kstream-Kstream 连接和 Ktream-Ktable 连接。我已将输入源主题分区计数从 4 更新为 16，并且应用程序因以下错误而停止。

Could not create internal topics: Existing internal topic application-test-processor-KSTREAM-JOINTHIS-0000000009-store-changelog has invalid partitions. Expected: 16 Actual: 4. Use 'kafka.tools.StreamsResetter' tool to clean up invalid topics before processing. Retry #3

当源主题分区计数更新时，如何更新内部变更日志主题分区计数？

注意：我们使用的kafka版本：0.10.2.1

我从此链接查看了应用程序重置工具：https://docs.confluence.io/current/streams/developer-guide/app-reset-tool.html ，但它没有说明如何更新更改日志分区。

提前致谢。