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.
Attachments
Issue Links
- links to