Our Single Message Transform (SMT) modifies the message to include the headers
in the value
field, and as such when we return the newRecord
we don’t define any headers:
override fun apply(record: T): T {
return record?.let { r ->
...
r.newRecord(r.topic(), r.kafkaPartition(), r.keySchema(), r.key(), null, value, r.timestamp())
}
}
According to the class: https://kafka.apache.org/24/javadoc/org/apache/kafka/connect/connector/ConnectRecord.html#ConnectRecord-java.lang.Str[…].lang.Object-java.lang.Long-
Do you have any idea how headers seem to be getting through still?