Hi, You can use KafkaSerializationSchema[1] which can create a ProducerRecord with Headers.
Best, Dawid [1] https://ci.apache.org/projects/flink/flink-docs-release-1.13/api/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializationSchema.html On 21/06/2021 12:58, Tan, Min wrote: > > Hi, > > > > I would like to add some meta data in the headers of kafka > messages using FlinkKakfkaProducer. > > I googled a bit and have not found an example. > > Which Flink Serialization Schema should I use? Any suggestions? > > > > Thank you very much for your help in advance. > > > > Regards, > > Min > > >
OpenPGP_signature
Description: OpenPGP digital signature
