Boyang Chen created KAFKA-9994: ---------------------------------- Summary: Catch TaskMigrated exception in task corruption code path Key: KAFKA-9994 URL: https://issues.apache.org/jira/browse/KAFKA-9994 Project: Kafka Issue Type: Bug Components: streams Reporter: Boyang Chen
We have seen a case where the TaskMigrated exception gets thrown from taskManager.commit(). This should be prevented by proper catching. -- This message was sent by Atlassian Jira (v8.3.4#803005)