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)