janchilling opened a new pull request, #19750: URL: https://github.com/apache/kafka/pull/19750
When an Exception is thrown while a StreamThread is created, a State Updater Thread is left hanging since it is created before the StreamThread constructor is called. Handled this from this commit after wrapping the code after the creation of the StateUpdater in the StreamThread#create by using a try catch block and manually shutting down the StateUpdater if an exception is thrown before a StreamThread is properly created. -- 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
