flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: How to add new Kafka topic to consumer
Date Wed, 11 Apr 2018 12:40:48 GMT
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.pancholi@flipkart.com 
> <mailto:Email-id%3Achandresh.pancholi@flipkart.com>
> Contact:08951803660



Mime
View raw message