框架:kafka+flink 1.13.2+postgreSQL 9.4.24+scala+数据库框架slick3.3
问题:flink消费kafka数据,如果不写入数据库,从flink收到kafka源数据开始就可以正常消费kafka,不会延迟
如果要写入数据库,从flink接收kafka数据开始就延迟(打印过源数据,源数据有时间字段,整个程序都没有使用水印时间),源端设备发送数据的频率不一样(有一分钟三条,一分钟两条,一分钟一条的),发送频率越快,flink消费越慢,而且不管什么频率,flink消费数据延迟会越来越高
这是生产环境的情况,测试环境可以秒写入
大佬们这是什么原因😭
flink消费kafka数据延迟
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
- 邀请回答
-
1条回答
相关推荐 更多相似问题
点击登录
提问题
悬赏问题
- ¥15 请问这个脚本bat清除tmp文件,会导致硬盘文件损坏吗?(操作系统-windows)
- ¥15 IncredBuild报错
- ¥15 锂电池偏最小二乘法参数辩识
- ¥15 session失效问题
- ¥15 GMS地下水数值模拟无法打开
- ¥15 树型结构的数据怎么匹配分支
- ¥15 stm32F4用.引不出来结构体成员怎么解决
- ¥30 Syntax Error: TypeError: this.getOptions is not a function的问题
- ¥15 eclipse Android环境搭建
- ¥15 unity中脚本之间的继承有什么作用