[ https://issues.apache.org/jira/browse/KAFKA-14250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Viktor Somogyi-Vass updated KAFKA-14250: ---------------------------------------- Labels: cloudera (was: ) > Exception during normal operation in MirrorSourceTask causes the task to fail > instead of shutting down gracefully > ----------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-14250 > URL: https://issues.apache.org/jira/browse/KAFKA-14250 > Project: Kafka > Issue Type: Bug > Components: KafkaConnect, mirrormaker > Affects Versions: 3.3 > Reporter: Viktor Somogyi-Vass > Assignee: Viktor Somogyi-Vass > Priority: Major > Labels: cloudera > Attachments: mm2.log > > > In MirrorSourceTask we are loading offsets for the topic partitions. At this > point, while we are fetching the partitions, it is possible for the offset > reader to be stopped by a parallel thread. Stopping the reader causes a > CancellationException to be thrown, due to KAFKA-9051. > Currently this exception is not caught in MirrorSourceTask and so the > exception propagates up and causes the task to go into FAILED state. We only > need it to go to STOPPED state so that it would be restarted later. > This can be achieved by catching the exception and stopping the task directly. -- This message was sent by Atlassian Jira (v8.20.10#820010)