Unable to deserialize Avro data using Pyflink

Posted by Zerah J on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Unable-to-deserialize-Avro-data-using-Pyflink-tp43752.html

Hi,

I have below use case

1. Read streaming data from Kafka topic using Flink Python API
2. Apply transformations on the data stream
3. Write back to different kafka topics based on the incoming data

Input data is coming from Confluent Avro Producer. By using the existing pyflink.common.serialization.AvroRowDeserializationSchema, I'm unable to deserialize the data.

Please help to process the data as ConfluentRegistryAvroDeserializationSchema is not available in the Python API.

Regards,

Zerah