Hello, I am currently working on program that uses flink to read avro type records from kafka. I have the avro schema of the records I want to read in a file but I looked all over github, the documentation and stack Overflow for examples on how to use AvroRowDeserializationSchema to deserialize a Kafka topic with Avro type but could not find any. Could you please provide an example using Python that is compatible with the Datastream API ?
Best Regards, Hussein Quiqup - Data Engineer
