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 very large (around 1500 lines for each topic), so I want to read it from a file instead of manually typing the types in the program. How can I do that? 1. How to specify deserialization schema for multiple topics (3 topics) 2. How to read the JSON schema from a file? https://stackoverflow.com/q/70892579/13067721?sem=2 Thanks in advance, Hussein Quiqup - Data Engineer
