[jira] [Created] (KAFKA-3734) Exceptions in SourceTask.commit() methods should cause task to stop and report failed state

["Ewen Cheslack-Postava (JIRA)" <ji...@apache.org>]

Ewen Cheslack-Postava created KAFKA-3734:
--------------------------------------------

             Summary: Exceptions in SourceTask.commit() methods should cause task to stop and report failed state
                 Key: KAFKA-3734
                 URL: https://issues.apache.org/jira/browse/KAFKA-3734
             Project: Kafka
          Issue Type: Bug
          Components: KafkaConnect
    Affects Versions: 0.10.0.0
            Reporter: Ewen Cheslack-Postava
            Assignee: Ewen Cheslack-Postava


https://github.com/apache/kafka/pull/1402 is catching exceptions and at least logging something useful, but we can't really ignore this type of exception. It implies something went wrong committing the data and we don't know if that will continue to happen indefinitely (and anything that is ok should be caught and handled by the connector).

This callback happens inside a Producer callback, so propagating the exception is not necessarily trivial.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)