RE: AvroRowDeserializationSchema

[lan tran]

Wonder if this is a bug or not but if I use AvroRowDeserializationSchema, In PyFlink the error still occure ? py4j.protocol.Py4JError: An error occurred while calling None.org.apache.flink.formats.avro.AvroRowDeserializationSchema. Trace: org.apache.flink.api.python.shaded.py4j.Py4JException: Constructor org.apache.flink.formats.avro.AvroRowDeserializationSchema([class org.apache.avro.Schema$RecordSchema]) does not exist Therefore, please help check. Thanks Best, Quynh     Sent from Mail for Windows   From: lan tran Sent: Thursday, April 21, 2022 1:43 PM To: user@flink.apache.org Subject: AvroRowDeserializationSchema   Hi team, I want to implement AvroRowDeserializationSchema when consume data from Kafka, however from the documentation, I did not understand what are avro_schema_string and record_class ? I would be great if you can give me the example on this (I only have the example on Java, however, I was doing it using PyFlink ). As my understanding avro_schema_string is schema_registry_url ? Does it support this  'debezium-avro-confluent.schema-registry.url'='{schema_registry_url}' like in TableAPI ? Best, Quynh. Sent from Mail for Windows