抱歉，您需设置社区昵称后才能参与社区互动！
【问题求助】
我使用flink opensource sql, 采用flink 1.10版本。
初期flink作业规划的kafka的分区数partition设置过小或过大，后期需要更改kafka区分数，很麻烦。如何不停止作业实现自动感知？
有人么
在sql语句中添加如下参数：
connector.properties.flink.partition-discovery.interval-millis="3000"
增加或减少kafka分区数，不用停止flink作业，可实现动态感知。
谢谢，我试试
发帖: 23粉丝: 3
标签：
分享文章到朋友圈
发帖: 16粉丝: 7
快速回复
您发表的内容存在敏感词汇
如点击继续发布，文章中的敏感词将正常发表。
有人么
在sql语句中添加如下参数：
增加或减少kafka分区数，不用停止flink作业，可实现动态感知。
谢谢，我试试