[GitHub] [kafka] dongjinleekr commented on a change in pull request #10507: KAFKA-8410: Migrating stateful operators to new Processor API

dongjinleekr commented on a change in pull request #10507: URL: https://github.com/apache/kafka/pull/10507#discussion_r644545454 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java ## @@ -16,6 +16,10 @@ */ package org.apache.ka

[GitHub] [kafka] dongjinleekr commented on a change in pull request #10507: KAFKA-8410: Migrating stateful operators to new Processor API

dongjinleekr commented on a change in pull request #10507: URL: https://github.com/apache/kafka/pull/10507#discussion_r644546368 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java ## @@ -16,6 +16,10 @@ */ package org.apache.ka

[GitHub] [kafka] dongjinleekr commented on a change in pull request #10507: KAFKA-8410: Migrating stateful operators to new Processor API

dongjinleekr commented on a change in pull request #10507: URL: https://github.com/apache/kafka/pull/10507#discussion_r644545454 ## File path: streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java ## @@ -16,6 +16,10 @@ */ package org.apache.ka