[GitHub] [kafka] mjsax commented on a change in pull request #8803: KAFKA-10102: update ProcessorTopology instead of rebuilding it

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

[GitHub] [kafka] mjsax commented on a change in pull request #8803: KAFKA-10102: update ProcessorTopology instead of rebuilding it

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()