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
E-mails can involve SUBS
