Description
The StateDirectory class is responsible for tracking the ownership of task directories, which may be locked by StreamThreads, the cleaner thread, or a user thread via KafkaStreams.cleanup(). It maintains a map from TaskId to the name of the owning thread.
We should consider tightening this up a bit and using a reference to the actual Thread instead of just the name.
Attachments
Issue Links
- links to