使用STATE_CLEANUP_DELAY_MS_CONFIG

Question

在StreamsConfig中有一个参数STATE_CLEANUP_DELAY_MS_CONFIG，它表示“在分区迁移时删除状态之前等待的时间量（以毫秒为单位）。仅删除至少state.cleanup.delay.ms未修改的状态目录”;

由于文件系统中的重新平衡，部署等，我们有多个状态目录

1. 这会清理那些目录吗？我尝试了这个参数，重新启动了消费者，但旧的状态目录仍在那里

Answer 1

请注意，Kafka Streams只会删除嵌套在state.dir中的任务目录，并且仅针对当前应用程序。因此，如果您有多个状态目录，因为您更改了application.id，则需要手动删除旧的状态目录。