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

Connect Error handling is using the RetriableException from common package

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.0.0
    • Fix Version/s: 2.0.2, 2.3.0, 2.1.2, 2.2.1
    • Component/s: KafkaConnect
    • Labels:
      None

      Description

      When a SourceConnector throws 

      org.apache.kafka.connect.errors.RetriableException during the poll, connect runtime is supposed to ignore the error and retry per https://cwiki.apache.org/confluence/display/KAFKA/KIP-298%3A+Error+Handling+in+Connect . When the conenctors throw the execption its not handled gracefully. 

      WorkerSourceTask is catching the exception from wrong package `org.apache.kafka.common.errors`.  It is not clear from the API standpoint as to which package the connect framework supports. The safest thing would be to support both the packages even though it's less desirable.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                mageshn Magesh kumar Nandakumar
                Reporter:
                mageshn Magesh kumar Nandakumar
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: