[ https://issues.apache.org/jira/browse/KAFKA-12509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
A. Sophie Blee-Goldman resolved KAFKA-12509. -------------------------------------------- Resolution: Fixed > Tighten up StateDirectory thread locking > ---------------------------------------- > > Key: KAFKA-12509 > URL: https://issues.apache.org/jira/browse/KAFKA-12509 > Project: Kafka > Issue Type: Improvement > Components: streams > Reporter: A. Sophie Blee-Goldman > Assignee: Ketul Gupta > Priority: Minor > Labels: newbie > Fix For: 3.0.0 > > > 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. -- This message was sent by Atlassian Jira (v8.3.4#803005)