[
https://issues.apache.org/jira/browse/FLINK-29361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607402#comment-17607402
]
Martijn Visser commented on FLINK-29361:
----------------------------------------
Can you elaborate on what you did in FlinkKafkaProducer which doesn't work for
you with KafkaSink? I don't think there should be a problem to write Kafka
headers.
> How to set headers with the new Flink KafkaSink
> -----------------------------------------------
>
> Key: FLINK-29361
> URL: https://issues.apache.org/jira/browse/FLINK-29361
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Reporter: Xin Hao
> Priority: Minor
>
> I'm using Flink 1.15.2, when I try to migrate to the new KafkaSink, it seems
> that it's not possible to add Kafka record headers.
> I think we should add this feature or document it if we already have it.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
