Hi Shamit, Why are specifying the upsert-kafka completely different? In particular, why did you set the serializer explicitly?
I would have assumed that just setting the format to 'format'='avro-confluent' should be enough (same as in the working source). On Tue, Feb 9, 2021 at 11:06 PM Shamit <jainsha...@gmail.com> wrote: > Hello Flink Users, > > Request you to please help. I am facing issue with "KafkaAvroDeserializer" > by using "upsert-kafka" connector. > > Regards, > Shamit Jain > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
