AvroRowDeserializationSchema

[lan tran]

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