建议使用以下浏览器,以获得最佳体验。 ie 9.0 以上版本 chrome 31 谷歌浏览器 firefox 30 火狐浏览器
温馨提示

抱歉,您需设置社区昵称后才能参与社区互动!

前往修改
我再想想
选择版块
数据湖探索 主题:267帖子:982

已解决

【问题求助】

dli flink作业如何动态感知kafka分区的变化

2021/5/28 5912

我使用flink opensource sql, 采用flink 1.10版本。

初期flink作业规划的kafka的分区数partition设置过小或过大,后期需要更改kafka区分数,很麻烦。如何不停止作业实现自动感知?


回复3

0 0
2021/5/28 10:35

有人么


0 0
2021/5/28 10:35

在sql语句中添加如下参数:

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

增加或减少kafka分区数,不用停止flink作业,可实现动态感知。

0 0
2021/5/28 10:36

谢谢,我试试

上划加载中
直达楼层
全部回复
正序浏览
标签
您还可以添加5个标签
  • 没有搜索到和“关键字”相关的标签
  • 云产品
  • 星辰平台的解决方案
  • 技术领域
  • 通用技术
  • 平台功能
取消

dli flink作业如何动态感知kafka分区的变化-星辰平台

您已采纳当前回复为最佳回复

发帖: 23粉丝: 3

发表于2021年05月28日 10:33:21 5912 3
直达本楼层的链接
楼主
[问题求助] dli flink作业如何动态感知kafka分区的变化

我使用flink opensource sql, 采用flink 1.10版本。

初期flink作业规划的kafka的分区数partition设置过小或过大,后期需要更改kafka区分数,很麻烦。如何不停止作业实现自动感知?


分享文章到朋友圈

分享文章到微博
您已采纳当前回复为最佳回复

发帖: 23粉丝: 3

发表于2021年05月28日 10:35:12

有人么


您已采纳当前回复为最佳回复

发帖: 16粉丝: 7

发表于2021年05月28日 10:35:55

在sql语句中添加如下参数:

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

增加或减少kafka分区数,不用停止flink作业,可实现动态感知。

您已采纳当前回复为最佳回复

发帖: 23粉丝: 3

发表于2021年05月28日 10:36:10

谢谢,我试试

您需要登录后才可以回帖 | 立即注册

邀请回答
您可以邀请3位专家
您对问题的回复是否满意?
满意度
非常满意 满意 一般 不满意
我要反馈
0/200