Alex Gout created FLINK-31049:
---------------------------------
Summary: Add support for Kafka record headers to KafkaSink
Key: FLINK-31049
URL: https://issues.apache.org/jira/browse/FLINK-31049
Project: Flink
Issue Type: Improvement
Components: Connectors / Kafka
Reporter: Alex Gout
The default org.apache.flink.connector.kafka.sink.KafkaSink does not support
adding Kafka record headers. In some implementations, downstream consumers
might rely on Kafka record headers being set.
The code responsible for creating the Kafka record involves
org.apache.flink.connector.kafka.sink.KafkaRecordSerializationSchemaWrapper
where the RecordProducer is created.
It is relatively simple to add support for record headers by adding a
"HeaderProducer" next to the key and value serializers and using the
appropriate RecordProducer constructor.
The issue was discussed
[here|https://lists.apache.org/thread/shlbbcqho0q9w5shjwdlscnsywjvbfro].
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
