FlinkKafakaProducer with Confluent SchemaRegistry and KafkaSerializationSchema

[Anil K]

Hi,

What is the best way to use Confluent SchemaRegistry with
FlinkKafkaProducer?

What I have right now is as follows.

SerializationSchema<GenericRecord> serializationSchema =
    ConfluentRegistryAvroSerializationSchema.forGeneric(topic, schema,
schemaRegistryUrl);

FlinkKafkaProducer<GenericRecord> kafkaProducer =
    new FlinkKafkaProducer<>(topic, serializationSchema, kafkaConfig);
outputStream.addSink(producer);

FlinkKafkaProducer with is SerializationSchema now depricated.

I am using flink 1.9.

How to use FlinkKafkaProducer with KafkaSerializationSchema with
ConfluentSchemaRegsitry?

Is there some reference/documentation i could use?

Thanks , Anil.