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
Jose Miguel Tejedor Fernandez Wed, 30 Aug 2017 06:32:12 -0700
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