Thanks Jiabao and Yaroslav for your quick responses.
Regards,
Kirti Dhar
From: Yaroslav Tkachenko
Sent: 01 February 2024 21:42
Cc: user@flink.apache.org
Subject: Re: RE: Flink Kafka Sink + Schema Registry + Message Headers
The schema registry support is provided
The schema registry support is provided
in ConfluentRegistryAvroSerializationSchema class
(flink-avro-confluent-registry package).
On Thu, Feb 1, 2024 at 8:04 AM Yaroslav Tkachenko
wrote:
> You can also implement a custom KafkaRecordSerializationSchema, which
> allows creating a ProducerRecord
You can also implement a custom KafkaRecordSerializationSchema, which
allows creating a ProducerRecord (see "serialize" method) - you can set
message key, headers, etc. manually. It's supported in older versions.
On Thu, Feb 1, 2024 at 4:49 AM Jiabao Sun wrote:
> Sorry, I didn't notice the
Sorry, I didn't notice the version information.
This feature was completed in FLINK-31049[1] and will be released in version
3.1.0 of Kafka.
The release process[2] is currently underway and will be completed soon.
However, version 3.1.0 does not promise support for Flink 1.16.
If you need to
