Flink SQL作业Kafka分区数增加或减少，怎样不停止Flink作业实现动态感知？

问题描述

用户执行Flink Opensource SQL, 采用Flink 1.10版本。初期Flink作业规划的Kafka的分区数partition设置过小或过大，后期需要更改Kafka区分数。

解决方案

在SQL语句中添加如下参数：

connector.properties.flink.partition-discovery.interval-millis="3000" 

增加或减少Kafka分区数，不用停止Flink作业，可实现动态感知。