Hi all, i'm pretty new to Flink and try to use pyflink data stream api. I want to connect to Confluent Cloud and read an avro topic with schema maintained in confluent schema registry. Now i face some issues deserializing the message and i was not able to fully understand if the Data Stream API supports Confluent Schema Registry avro messages or do i need to use the Table API for that which has a Confluent Avro Format? Schema string is what i receive properly from confluent cloud but when i use the schema string from confluent for deserialization

deserialization_schema = AvroRowDeserializationSchema(
        avro_schema_string=schema_str_source
    )

i receive an error when executing

org.apache.flink.avro.shaded.org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -1

Thanks and cheecrs, marcus