Hi, Would it be possible to get the FlinkKafkaConsumer to support multiple topics, like a list?
Or would it be better to instantiate one FlinkKafkaConsumers per topic and add as a source? We have about 40-50 topics to listen for one job. Or even better, supply a regexp pattern that defines the queues, this means that you have to do some queries against ZK to get information about topics. Kind regards, Jakob