For questions like this one, please address them to either Stack Overflow or the user mailing list, but not both at once. Those two forums are appropriate places to get help with using Flink's APIs. And once you've asked a question, please allow some days for folks to respond before trying again.
The dev and community mailing lists are dedicated to other topics, and aren't suitable for getting help. The community list is for discussions related to meetups and conferences, and the dev list is for discussions and decision making about the ongoing development of Flink itself. In the interest of not further spamming the dev and community lists, let's limit the follow-up on deserializers to the user ML. Best regards, David On Fri, Jan 28, 2022 at 12:07 PM Hussein El Ghoul <huss...@quiqup.com> wrote: > 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