[ 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)