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.
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