frankvicky commented on code in PR #23004:
URL: https://github.com/apache/kafka/pull/23004#discussion_r3948242474
##########
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java:
##########
@@ -804,6 +807,98 @@ public void shouldRemoveThread() throws Exception {
}
}
+ @Test
+ @Timeout(60)
+ public void shouldNotBlockOtherThreadChangesWhileRemovalWaitsForShutdown()
throws Exception {
+ // `removeStreamThread` used to wait for the removed thread to reach
DEAD while holding
Review Comment:
Reworded to describe what the test verifies now rather than the old bug.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
