smjn opened a new pull request, #23659: URL: https://github.com/apache/kafka/pull/23659
- When record copy is enabled for a share group's DLQ, ShareGroupDLQRecordHelper.headers() now preserves the original source record's headers on the DLQ record instead of discarding them. - If an original header's key collides with a DLQ context header that is actually added for that record — unconditionally for topic/partition/offset/group, conditionally for delivery-count/cause when present — the original header is dropped so the DLQ-computed value is the only one present. - Headers are now built RecordHeaders instead of hand-rolled array/size bookkeeping, removing a class of size/counter-mismatch risk on future edits. -- 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]
