Read Avro type records from kafka using Python - Datastream API

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

Read Avro type records from kafka using Python - Datastream API

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

Read Json deserialization schema from file

Hello, How to specify the deserialization schema for multiple Kafka topics using Flink (python) I want to read from multiple Kafka topics with JSON schema using FlinkKafkaConsumer, and I assume that I need to use JsonRowDeserializationSchema to deserialize the data. The schema of the topics is v