Hi everyone,
I'd like to start the voting thread for KIP-1259, which addresses the "zombie data" issue in Kafka Streams. This occurs when an instance restarts with stale local files after the changelog's tombstones have been purged (exceeding delete.retention.ms). We propose adding new property (state.cleanup.on.start.delay.ms) to allow an automated wipe of local state if it exceeds a specific age, ensuring the store is rebuilt from the broker. KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1259%3A+Add+configuration+to+wipe+Kafka+Streams+local+state+on+startup Discussion thread: https://lists.apache.org/thread/rd4hosz31y5lv9nqm85qkj727jw024mq Best Regards, Uladzislau Blok
