subject:"\[GitHub\] \[kafka\] guozhangwang commented on a change in pull request #9247\: KAFKA\-10362\: When resuming Streams active task with EOS, the checkpoint file is deleted"

[GitHub] [kafka] guozhangwang commented on a change in pull request #9247: KAFKA-10362: When resuming Streams active task with EOS, the checkpoint file is deleted

2020-09-15 Thread GitBox

guozhangwang commented on a change in pull request #9247: URL: https://github.com/apache/kafka/pull/9247#discussion_r489156100 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java ## @@ -662,4 +662,10 @@ public TopicPartit

[GitHub] [kafka] guozhangwang commented on a change in pull request #9247: KAFKA-10362: When resuming Streams active task with EOS, the checkpoint file is deleted

2020-09-09 Thread GitBox

guozhangwang commented on a change in pull request #9247: URL: https://github.com/apache/kafka/pull/9247#discussion_r485941828 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java ## @@ -662,4 +662,10 @@ public TopicPartit