Hi team, I am trying to deserialize Confluent Avro from Schema Registry, but the AvroRowDeserializationSchema function does not seem to be working. I have searched for this problem online but have not been able to find a solution. Can anyone suggest what I should do?

avro_deserialization_schema = AvroRowDeserializationSchema(avro_schema_string=avro_schema)

consumer = FlinkKafkaConsumer(
    topics=topic_name,
    deserialization_schema=avro_deserialization_schema,
    properties=kafka_props
)