[GitHub] [kafka] bbejeck commented on a change in pull request #9221: KAFKA-10436: Implement KIP-478 Topology changes

bbejeck commented on a change in pull request #9221: URL: https://github.com/apache/kafka/pull/9221#discussion_r485754938 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java ## @@ -99,5 +99,14 @@ public void

[GitHub] [kafka] bbejeck commented on a change in pull request #9221: KAFKA-10436: Implement KIP-478 Topology changes

bbejeck commented on a change in pull request #9221: URL: https://github.com/apache/kafka/pull/9221#discussion_r48569 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java ## @@ -99,5 +99,14 @@ public void