[GitHub] [kafka] vvcephei commented on a change in pull request #8667: KAFKA-9994: Handle task migrated inside corruption path

vvcephei commented on a change in pull request #8667: URL: https://github.com/apache/kafka/pull/8667#discussion_r425386296 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java ## @@ -555,28 +555,35 @@ void runLoop() {

[GitHub] [kafka] vvcephei commented on a change in pull request #8667: KAFKA-9994: Handle task migrated inside corruption path

vvcephei commented on a change in pull request #8667: URL: https://github.com/apache/kafka/pull/8667#discussion_r425348145 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java ## @@ -555,28 +555,35 @@ void runLoop() {