[jira] [Resolved] (KAFKA-5774) WorkerSinkTask failure exception should include cause

["Randall Hauch (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-5774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Randall Hauch resolved KAFKA-5774.
----------------------------------
       Resolution: Fixed
    Fix Version/s: 1.0.0

Indeed, this was [fixed with this PR|https://github.com/apache/kafka/pull/3639] as mentioned above: https://github.com/apache/kafka/blob/11afff09908035166febf9b75c410112693ff98c/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java#L515

> WorkerSinkTask failure exception should include cause
> -----------------------------------------------------
>
>                 Key: KAFKA-5774
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5774
>             Project: Kafka
>          Issue Type: Bug
>          Components: KafkaConnect
>    Affects Versions: 0.11.0.0
>            Reporter: Randall Hauch
>             Fix For: 1.0.0
>
>
> When the WorkerSinkTask shuts down because of a connector exception, the task throws an exception with the message like the following:
> {code}
> 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)
>         ...
> {code}
> 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.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)