chickenchickenlove opened a new pull request, #20969: URL: https://github.com/apache/kafka/pull/20969
### Summary `KafkaStreams#cleanup(...)` currently logs a `WARN` when the state directory cannot be deleted because it is not empty. Since KAFKA-10716, the `processId` file is persisted in state directory and is expected to remain across restarts, so this WARN can be misleading when the process metadata file is the only remaining entry. ### Changes - In `StateDirectory#clean(...)`, If the directory contains only the `process metadata` file, a debug message is logged explaining that the directory was not deleted because it still contains the process metadata file required for stable task assignment across restarts, and no WARN is emitted. If any other file remains, the existing WARN is logged as before. ### Related Ticket - https://issues.apache.org/jira/browse/KAFKA-17251 - https://issues.apache.org/jira/browse/KAFKA-10212 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
