[jira] [Created] (KAFKA-15216) InternalSinkRecord::newRecord method ignores the headers argument

[Yash Mayya (Jira)]

Yash Mayya created KAFKA-15216:
----------------------------------

             Summary: InternalSinkRecord::newRecord method ignores the headers 
argument
                 Key: KAFKA-15216
                 URL: https://issues.apache.org/jira/browse/KAFKA-15216
             Project: Kafka
          Issue Type: Bug
          Components: KafkaConnect
            Reporter: Yash Mayya
            Assignee: Yash Mayya


[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.|https://github.com/apache/kafka/pull/14024#discussion_r1266917499]



--
This message was sent by Atlassian Jira
(v8.20.10#820010)