[KAFKA-5774] WorkerSinkTask failure exception should include cause

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.11.0.0
• Fix Version/s: 1.0.0
• Component/s: connect
• Assignee: Unassigned
• Reporter: Randall Hauch
• Created: 23/Aug/17 23:11
• Updated: 09/Oct/17 14:20
• Resolved: 09/Oct/17 14:20

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.