mjsax commented on a change in pull request #8803:
URL: https://github.com/apache/kafka/pull/8803#discussion_r436188699
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java
##
@@ -131,6 +142,23 @@ public boolean hasPersistentG
mjsax commented on a change in pull request #8803:
URL: https://github.com/apache/kafka/pull/8803#discussion_r436188966
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -512,18 +510,16 @@ public void closeAndRecycleState()