Nico Pommerening created KAFKA-13787:
----------------------------------------
Summary: Failed to delete state store directory for it is not empty
Key: KAFKA-13787
URL: https://issues.apache.org/jira/browse/KAFKA-13787
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 3.0.0
Reporter: Nico Pommerening
Attachments: bug-log.txt
On Kafka Streams shutdown the Cleanup of state directories seems not to work,
since the lock and metadata file seem not to be deleted.
Relevant WARN logging:
2022-03-31 10:34:41,689 WARN [SpringApplicationShutdownHook]
org.apache.kafka.streams.processor.internals.StateDirectory: stream-thread
[SpringApplicationShutdownHook] Failed to delete state store directory of
/kafka-streams-statestore/555b9965-95e3-4c92-b467-1d283428da5d/test-test-run-kpi
for it is not empty
Left over files in directory:
* .lock
* kafka-streams-process-metadata
I'm not sure what the consequences of a unclean state cleanup are, but I would
like to get rid of the Warning.
I attached a bigger log extract and I've already patched the StateDirectory
implementation which I'll try to contribute.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
