[GitHub] [kafka] lct45 commented on a change in pull request #9487: KAFKA-9331 add a streams handler

lct45 commented on a change in pull request #9487: URL: https://github.com/apache/kafka/pull/9487#discussion_r514535737 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java ## @@ -282,6 +284,15 @@ public boolean isRunning() {

[GitHub] [kafka] lct45 commented on a change in pull request #9487: KAFKA-9331 add a streams handler

lct45 commented on a change in pull request #9487: URL: https://github.com/apache/kafka/pull/9487#discussion_r514527605 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -346,26 +351,89 @@ public void setStateListener(final