Hi Kafka Community! I would like to start a discussion for KIP-1283. This KIP proposes updating the KafkaStreams#cleanUp() contract to explicitly preserve process identity metadata and lock files, avoiding misleading WARN logs while ensuring stable process identity across restarts. Currently, KafkaStreams#cleanUp() deletes the local state but attempts to delete the application directory itself as the final step. However, this directory deletion often fails because expected metadata files (kafka-streams-process-metadata and .lock) remain. This results in misleading WARN logs, causing confusion for users and operators who interpret it as a local state cleanup failure. This KIP clarifies that retaining these specific files is considered a successful cleanup and suppresses the unnecessary warnings.
KIP LINK: https://cwiki.apache.org/confluence/x/mYw8G Looking forward to community's feedback! Best regards, Sanghyeok An
