Viktor Somogyi-Vass created KAFKA-14250:
-------------------------------------------
Summary: 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
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)
