[
https://issues.apache.org/jira/browse/FLINK-31049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688153#comment-17688153
]
Yaroslav Tkachenko commented on FLINK-31049:
--------------------------------------------
Hi Alex,
Would you mind correcting the language a little bit? KafkaSink does allow
setting headers by accepting a custom {{KafkaRecordSerializationSchema}} via
{{setRecordSerializer}} method. You don't need to use
{{{}KafkaRecordSerializationSchemaWrapper{}}}.
Would you add HeaderProducer as a top-level entity for the KafkaSink?
> 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
> Priority: Minor
> Labels: KafkaSink
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> 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)
