You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2018/06/11 22:18:00 UTC
[jira] [Resolved] (KAFKA-7003) Add headers with error context in
messages written to the Connect DeadLetterQueue topic
[ https://issues.apache.org/jira/browse/KAFKA-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ewen Cheslack-Postava resolved KAFKA-7003.
------------------------------------------
Resolution: Fixed
Fix Version/s: 2.1.0
2.0.0
Issue resolved by pull request 5159
[https://github.com/apache/kafka/pull/5159]
> Add headers with error context in messages written to the Connect DeadLetterQueue topic
> ---------------------------------------------------------------------------------------
>
> Key: KAFKA-7003
> URL: https://issues.apache.org/jira/browse/KAFKA-7003
> Project: Kafka
> Issue Type: Task
> Reporter: Arjun Satish
> Priority: Major
> Fix For: 2.0.0, 2.1.0
>
>
> This was added to the KIP after the feature freeze.
> If the property {{errors.deadletterqueue.}}{{context.headers.enable}} is set to {{*true*}}, the following headers will be added to the produced raw message (only if they don't already exist in the message). All values will be serialized as UTF-8 strings.
> ||Header Name||Description||
> |__connect.errors.topic|Name of the topic that contained the message.|
> |__connect.errors.task.id|The numeric ID of the task that encountered the error (encoded as a UTF-8 string).|
> |__connect.errors.stage|The name of the stage where the error occurred.|
> |__connect.errors.partition|The numeric ID of the partition in the original topic that contained the message (encoded as a UTF-8 string).|
> |__connect.errors.offset|The numeric value of the message offset in the original topic (encoded as a UTF-8 string).|
> |__connect.errors.exception.stacktrace|The stacktrace of the exception.|
> |__connect.errors.exception.message|The message in the exception.|
> |__connect.errors.exception.class.name|The fully qualified classname of the exception that was thrown during the execution.|
> |__connect.errors.connector.name|The name of the connector which encountered the error.|
> |__connect.errors.class.name|The fully qualified name of the class that caused the error.|
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)