Re: Stack Overflow Question - Deserialization schema for multiple topics

2022-01-28 Thread David Anderson
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.

Stack Overflow Question - Deserialization schema for multiple topics

2022-01-28 Thread Hussein El Ghoul
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