Re: Proposal to add support for Kafka Headers to KafkaRecordSerializationSchemaWrapper

Hi Alex, Just assigned the ticket to you. Kafka Header should be supported as we started implementing the KafkaSink. Thanks for driving this! Best regards, Jing On Fri, Feb 17, 2023 at 3:35 PM Alex Gout wrote: > Hey :) > I created a JIRA for

Re: Proposal to add support for Kafka Headers to KafkaRecordSerializationSchemaWrapper

Hey :) I created a JIRA for it. Can someone assign it to me? On Mon, Feb 13, 2023 at 3:17 PM Márton Balassi wrote: > Hi Alex, > > Please do share, this comes up somewhat frequently. > > Marton > > On Mon, Feb 13, 2023 at 7:44 PM Őrhidi Mátyás

Re: Proposal to add support for Kafka Headers to KafkaRecordSerializationSchemaWrapper

Hi Alex, Please do share, this comes up somewhat frequently. Marton On Mon, Feb 13, 2023 at 7:44 PM Őrhidi Mátyás wrote: > Hi Alex, > > This is a reasonable request IMO. I've recently bumped into this topic > myself. This could be handy for supporting schema registries in Kafka to > Kafka

Re: Proposal to add support for Kafka Headers to KafkaRecordSerializationSchemaWrapper

Hi Alex, This is a reasonable request IMO. I've recently bumped into this topic myself. This could be handy for supporting schema registries in Kafka to Kafka scenarios for example. Looking forward to your proposal. Cheers, Matyas On Mon, Feb 13, 2023 at 7:08 AM Alex Gout wrote: > Hi all, > >

Proposal to add support for Kafka Headers to KafkaRecordSerializationSchemaWrapper

Hi all, I'm currently working on a few pipelines sinking to Kafka. The downstream consumers of the sink topics expect some Kafka headers to be set. However the default org.apache.flink.connector.kafka.sink.KafkaSink does not support adding Kafka record headers. I tracked the code path down to