to your proposal.
> >
> > Cheers,
> > Matyas
> >
> > On Mon, Feb 13, 2023 at 7:08 AM Alex Gout >
> > wrote:
> >
> > > Hi all,
> > >
> > > I'm currently working on a few pipelines sinking to Kafka. The
> downstream
>
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
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
org
