Re: kafka分区数扩容对flink任务的影响

hi
Flink是可以感知到partition的增加的
消费kafka的时候设置一下KEY_PARTITION_DISCOVERY_INTERVAL_MILLIS这个参数 大于0就可以了




--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复