mjsax commented on code in PR #16337: URL: https://github.com/apache/kafka/pull/16337#discussion_r1639096220
########## streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java: ########## @@ -635,14 +634,10 @@ public void setStandbyUpdateListener(final StandbyUpdateListener standbyListener final class StreamStateListener implements StreamThread.StateListener { private final Map<Long, StreamThread.State> threadState; private GlobalStreamThread.State globalThreadState; - // this lock should always be held before the state lock - private final Object threadStatesLock; - StreamStateListener(final Map<Long, StreamThread.State> threadState, - final GlobalStreamThread.State globalThreadState) { - this.threadState = threadState; + StreamStateListener(final GlobalStreamThread.State globalThreadState) { Review Comment: Orthogonal question: should we also make this class a singleton? It's use correctly with a single instance right now but might be good to enforce it additionally to guard against future mistakes? -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org