flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Piotr Nowojski <pi...@data-artisans.com>
Subject Re: Modify field topics (KafkaConsumer) during runtime
Date Thu, 31 Aug 2017 07:32:45 GMT

As far as I know it is not possible to do it on the fly. There is planned feature for discovering
topics using some regex:
https://github.com/apache/flink/pull/3746 <https://github.com/apache/flink/pull/3746>
https://issues.apache.org/jira/browse/FLINK-5704 <https://issues.apache.org/jira/browse/FLINK-5704>
But it is not completed yet.

Thanks, Piotrek

> On Aug 30, 2017, at 3:31 PM, Jose Miguel Tejedor Fernandez <jose.fernandez@rovio.com>
> Hi,
> I am using Flink version 1.3.1.
> I am wondering if it is possible to add/delete new topics to FlinkKafkaConsumer during
execution of a job? Otherwise, I guess I need to cancel the job and redeploy the new job.
> Cheers
> BR

View raw message