aashish-confluent opened a new pull request, #24075: URL: https://github.com/apache/kafka/pull/24075
Remove the __streams.errors.* headers copied from the failed record in ExceptionHandlerUtils.buildDeadLetterQueueRecord before adding the new ones, so each error header appears once in the DLQ record with the value for the current failure. Other headers of the failed record are still copied. Added a unit test in ExceptionHandlerUtilsTest. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
