建议使用以下浏览器,以获得最佳体验。 IE 9.0+以上版本 Chrome 31+ 谷歌浏览器 Firefox 30+ 火狐浏览器
请选择 进入手机版 | 继续访问电脑版
设置昵称

在此一键设置昵称,即可参与社区互动!

确定
我再想想
选择版块
直达楼层
标签
您还可以添加5个标签
  • 没有搜索到和“关键字”相关的标签
  • 云产品
  • 解决方案
  • 技术领域
  • 通用技术
  • 平台功能
取消

采纳成功

您已采纳当前回复为最佳回复
发表于2021年05月28日 10:33:21 1083 3
直达本楼层的链接
楼主
显示全部楼层
[问题求助] DLI Flink作业如何动态感知Kafka分区的变化

我使用Flink Opensource SQL, 采用Flink 1.10版本。

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


举报
分享

分享文章到朋友圈

分享文章到微博

采纳成功

您已采纳当前回复为最佳回复
发表于2021年05月28日 10:35:12
直达本楼层的链接
沙发
显示全部楼层

有人么


点赞 评论 引用 举报

采纳成功

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

Yunz Bao

发帖: 16粉丝: 5

级别 : 版主,版块专家

发消息 + 关注

发表于2021年05月28日 10:35:55
直达本楼层的链接
板凳
显示全部楼层

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

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

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

点赞 评论 引用 举报

采纳成功

您已采纳当前回复为最佳回复
发表于2021年05月28日 10:36:10
直达本楼层的链接
地板
显示全部楼层

谢谢,我试试

点赞 评论 引用 举报

游客

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

邀请回答
您可以邀请3位专家

结贴

您对问题的回复是否满意?
满意度
非常满意 满意 一般 不满意
我要反馈
0/200