In 1.3 and below I believe this is not possible.
For 1.4 and above, please see
https://ci.apache.org/projects/flink/flink-docs-master/dev/connectors/kafka.html#partition-discovery.
On 11.04.2018 14:33, chandresh pancholi wrote:
Hi,
Is there a way to add Kafka topic dynamically to stream?
For example there were Kafka topic named foo1, foo2, foo3 and task
manager will start consuming events from all 3 topics. Now I create
another two topic foo4 & bar1 in Kafka.
How will FlinkKafkaConsumer would read events from foo4 & bar1 topic?
Thanks
--
Chandresh Pancholi
Senior Software Engineer
Flipkart.com
Email-id:chandresh.panch...@flipkart.com
<mailto:email-id%3achandresh.panch...@flipkart.com>
Contact:08951803660
