Hi Shamit,
I think the main problem is the wrong usage of the upsert kafka ddl. In the
ddl, you use avro as the format rather than avro-confluent.
The dev mail list is used to discuss implementation details. Please send
emails to user mail list for help.
[1] https://flink.apache.org/gettinghelp.
Hello Team,
I am facing issue with "upsert-kafka" connector which should read the Avro
message serialized using
"io.confluent.kafka.serializers.KafkaAvroDeserializer". Same is working with
"kafka" connector.
Looks like we are not able to pass the schema registry url and subject name
like the way
