如何删除/清除 Kafka Streams 中的状态存储？

我有一个习惯Transformer在我的 kafka-streams DSL 的末尾实现，并带有持久的变更日志KeyValueStore绑定到它。

几周以来，我在商店里放了太多的数据。现在，每当我加载应用程序时，它就会消耗太多的内存。

然而，应用程序本身只是一个原型，所以我不介意完全清理商店。

我可以重命名kafka.application.id和state-store-name但这是一个临时解决方法（并且相应的数据/主题不会被删除）。

我该如何彻底清除它？

合流的文档建议 https://docs.confluent.io/platform/current/streams/developer-guide/app-reset-tool.html#step-2-reset-the-local-environments-of-your-application-instances使用 KafkaStreams.cleanUp()，或手动删除目录/var/lib/kafka-streams/<application.id>（配置参数state.dir).

您还需要使用以下命令重置应用程序使用的所有主题专用重置工具 https://docs.confluent.io/platform/current/streams/developer-guide/app-reset-tool.html - bin/kafka-streams-application-reset:

bin/kafka-streams-application-reset --application-id my-streams-app \
                                  --input-topics my-input-topic \
                                  --intermediate-topics rekeyed-topic

This post https://www.confluent.io/blog/data-reprocessing-with-kafka-streams-resetting-a-streams-application/关于重置状态非常有趣。