CoderMurphy 2022-01-28 09:47 采纳率: 100%
浏览 296
已结题

flink消费kafka数据延迟

框架:kafka+flink 1.13.2+postgreSQL 9.4.24+scala+数据库框架slick3.3
问题:flink消费kafka数据,如果不写入数据库,从flink收到kafka源数据开始就可以正常消费kafka,不会延迟
如果要写入数据库,从flink接收kafka数据开始就延迟(打印过源数据,源数据有时间字段,整个程序都没有使用水印时间),源端设备发送数据的频率不一样(有一分钟三条,一分钟两条,一分钟一条的),发送频率越快,flink消费越慢,而且不管什么频率,flink消费数据延迟会越来越高
这是生产环境的情况,测试环境可以秒写入
大佬们这是什么原因😭

img

img

img

img

img

img

img

  • 写回答

1条回答 默认 最新

      报告相同问题?

      相关推荐 更多相似问题

      问题事件

      • 系统已结题 2月6日
      • 已采纳回答 1月29日
      • 创建了问题 1月28日

      悬赏问题

      • ¥25 接口/特征方法的异常错误返回如何判断是否需要设计
      • ¥40 代码+预测分析,文件私信发哦(价格可商量)
      • ¥15 GAMES101 HW1 无法定义
      • ¥15 pycharm不管允许什么代码都出错,都会出现下面的情况。
      • ¥15 boost::integrate的用法
      • ¥20 51单片机输出pwm时无法调节频率,如何解决?
      • ¥15 DSP28335 AD采集正弦波
      • ¥50 pwwinauto调式修改
      • ¥30 关于#单片机#的问题:单片机基于51单片机开发计时器,使其实现以下功能:(1)开发板上四个独立按键分别控制计时器的启停、计时器的复位(按下计时值归零)、计时位切换、计时时间的递增
      • ¥15 看个代码。做个详细的解说