janchilling opened a new pull request, #19889: URL: https://github.com/apache/kafka/pull/19889
…n StreamThreadTest fix Updated the code to start the State Updater Thread only after the Stream Thread is started. Changes done : 1. Moved the starting of the StateUpdater thread to a new init method in the TaskManager. 2. Called the init of TaskManager in the run method of the StreamThread. 3. Updated the test cases in the StreamThreadTest to mimic the aforementioned behaviour. -- 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