Boyang Chen created KAFKA-10813:
-----------------------------------
Summary: StreamsProducer should catch InvalidProducerEpoch and
throw TaskMigrated in all cases
Key: KAFKA-10813
URL: https://issues.apache.org/jira/browse/KAFKA-10813
Project: Kafka
Issue Type: Bug
Reporter: Boyang Chen
Fix For: 2.7.0
We fixed the error code handling on producer in
https://issues.apache.org/jira/browse/KAFKA-10687, however the newly thrown
`InvalidProducerEpoch` exception was not properly handled on Streams side in
all cases. We should catch it and rethrow as TaskMigrated to trigger exception,
similar to ProducerFenced.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
