[KAFKA-15216] InternalSinkRecord::newRecord method ignores the headers argument

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.3.3, 3.6.0, 3.4.2, 3.5.2
• Component/s: connect
• Assignee: Yash Mayya
• Reporter: Yash Mayya
• Reviewer: Chris Egerton
• Created: 19/Jul/23 06:37
• Updated: 20/Jul/23 14:39
• Resolved: 20/Jul/23 14:23

Description

https://github.com/apache/kafka/blob/a1f6ab69387deb10988461152a0087f0cd2827c4/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java#L50-L56 - the headers argument passed to the InternalSinkRecord constructor is the instance field via the accessor headers() method instead of the newRecord method's headers argument value.

 

Originally discovered here.

Issue Links

• links to: GitHub Pull Request #14044