'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?
- How to specify deserialization schema for multiple topics (3 topics)
- How to read the JSON schema from a file?
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
| Solution | Source |
|---|