我在我的 kafka-streams DSL 末尾有一个自定义的 Transformer 实现，并绑定了一个持久的更改日志 KeyValueStore。
几周以来，我在商店中存储了太多数据。现在，每当我加载应用程序时，它都会占用太多 RAM。
但是，应用程序本身只是一个原型，所以我不介意彻底清除商店。
我可以重命名kafka.application.id 和state-store-name，但这是临时解决方法（并且不会删除相应的数据/主题）。
如何彻底清除它？
【问题讨论】：
标签： apache-kafka apache-kafka-streams
Confluent 的documentation recommends 要么使用KafkaStreams.cleanUp()，要么手动删除/var/lib/kafka-streams/<application.id> 处的目录（配置参数state.dir）。
您还需要使用special reset tool - bin/kafka-streams-application-reset 重置应用程序使用的所有主题：
bin/kafka-streams-application-reset --application-id my-streams-app \
--input-topics my-input-topic \
--intermediate-topics rekeyed-topic
这个关于重置状态的post很有意思。
【讨论】：