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.