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

Reply via email to