vitojeng commented on a change in pull request #10668: URL: https://github.com/apache/kafka/pull/10668#discussion_r640217904
########## File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java ########## @@ -491,25 +493,23 @@ public void testStateThreadClose() throws Exception { () -> streams.localThreadsMetadata().stream().allMatch(t -> t.threadState().equals("DEAD")), "Streams never stopped" ); - } finally { streams.close(); Review comment: @mjsax Thanks for the detail description. I knew the things you describe. But in this case, after `streams.close()` , we still need to check streams state whether is `NOT_RUNNING`. If we remove `streams.close()`, the streams state will still be `RUNNING`, this state will lead to failed of the next checking of `NOT_RUNNING`. -- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org