戈震 created KAFKA-12632:
--------------------------
Summary: Exception may missed when source task failing
Key: KAFKA-12632
URL: https://issues.apache.org/jira/browse/KAFKA-12632
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Affects Versions: 2.6.1
Reporter: 戈震
When task get a exception, it will jump out of while block and call method
commitOffsets() in finally block in method
org.apache.kafka.connect.runtime.WorkerSourceTask.execute().
But if there is a exception thrown in commitOffsets(), the origin exception
instance will be missed.
{code:java}
//代码占位符
package org.apache.kafka.connect.runtime;
class WorkerSourceTask extends WorkerTask {
@Override
public void execute() {
try {
// throw some exception.
} catch (InterruptedException e) {
} finally {
// if some exception thrown in this method, the origin exception
will be missed
commitOffsets();
}
}
}
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
