[
https://issues.apache.org/jira/browse/KAFKA-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504338#comment-16504338
]
ASF GitHub Bot commented on KAFKA-7003:
---------------------------------------
wicknicks opened a new pull request #5159: KAFKA-7003: Set error context in
message headers (KIP-298)
URL: https://github.com/apache/kafka/pull/5159
If the property `errors.deadletterqueue.context.headers.enable` is set to
true, add a set of headers to the messages describing the context under which
the error took place.
A unit test is added to check the correctness of header creation.
Signed-off-by: Arjun Satish <ar...@confluent.io>
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> 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
>
> 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)
