apache-kafka - Kafka Stream - 每天早上回收状态

Question

我有一个KafkaStream应用程序有多个连接KTable。最后，我使用Processor Api形成State Store来执行某种业务逻辑。早些时候，我有一个清除工作正在删除Kafka日志，并且KafkaStream's state dir每天早上只处理我的producers. 到目前为止，一切都按预期工作。

但是删除 Kafka 日志目录并不是一个好方法，所以我决定利用cleanup.policy从 Kafka 中删除数据并删除 KafkaStream state dirs。我认为这种方法在应用启动时state stores仍然从主题重新存储数据的地方产生了问题。changelog

有没有办法从主题中清除Kafka整个KafkaStream's state store数据changelog？

感谢你的帮助。

标签： apache-kafkaapache-kafka-streams