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

WorkerSinkTask failure exception should include cause

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.11.0.0
    • Fix Version/s: 1.0.0
    • Component/s: KafkaConnect
    • Labels:
      None

      Description

      When the WorkerSinkTask shuts down because of a connector exception, the task throws an exception with the message like the following:

      ERROR Task Vital-ElasticsearchSinkConnector-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:141)
      org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.
      	at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:451)
              ...
      

      without any information about the exception that caused the task to fail. The cause is logged just prior to this error, but it would be more helpful for the shutdown error message to include the cause.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              rhauch Randall Hauch
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: