Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-3734

Exceptions in SourceTask.commit() methods should cause task to stop and report failed state

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 0.10.0.0
    • None
    • connect
    • None

    Description

      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.

      Attachments

        Activity

          People

            liquanpei Liquan Pei
            ewencp Ewen Cheslack-Postava
            Ewen Cheslack-Postava Ewen Cheslack-Postava
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: