ableegoldman commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r563978428
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -612,11 +612,22 @@ public void
ableegoldman commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r563978428
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -612,11 +612,22 @@ public void
ableegoldman commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r562882284
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -612,11 +612,22 @@ public void
ableegoldman commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r562815151
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -612,11 +612,22 @@ public void
ableegoldman commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r562813288
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -249,20 +249,31 @@ public boolean isValidTransition(final State
ableegoldman commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r556176651
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -249,20 +249,31 @@ public boolean isValidTransition(final State
ableegoldman commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r556176651
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -249,20 +249,31 @@ public boolean isValidTransition(final State
ableegoldman commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r556176651
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -249,20 +249,31 @@ public boolean isValidTransition(final State
ableegoldman commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r556039219
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -249,20 +249,31 @@ public boolean isValidTransition(final State