更新时间:2025-08-27 GMT+08:00
分享

MySQL源端作业如何查看已消费位点?

本文介绍四种方式确认作业的已消费位点,用户可以根据实际情况采取不同方案。

运行中作业从监控指标界面查看“已消费位点”

  1. 前往作业监控界面。
    图1 前往作业监控

  2. 选择“实时集成作业监控”页签。
    图2 实时集成作业监控

  3. 单击作业名,进入监控信息界面,刷新作业同步进度。
    图3 监控信息

    以上,binlog时间戳即为已消费位点,重启作业时可以将这个时间设置为启动时间以防止丢数。

通过taskmanager日志查看已消费位点

  1. 下载jobmanager日志,搜索关键字“Completed checkpoint”找到最新的一次已完成checkpoint,以下可以看到“checkpoint 8”为最新完成的检查点。
    图4 下载jobmanager日志

    图5 搜索Completed checkpoint
  2. 下载taskmanager日志,搜索关键字“Binlog offset on checkpoint 8”,获取对应位点的ts_sec即为已消费位点。
    图6 下载taskmanager日志

    图7 搜索Binlog offset on checkpoint 8

注意:当作业存在多并发时会有多个taskmanager日志,只有其中的某一个taskmanager日志包含binlog offset信息。

异常或已暂停状态下的作业,单击“恢复”按钮后在位点设置弹窗查看已同步位点

异常或者已暂停的作业,单击恢复按钮,可以在“恢复配置”界面查看“时间”一项,确认已消费位点时间。单击确认后,作业实际会从这个时间点继续消费数据。

注意:全量+增量启动的作业单击恢复后不会有“恢复配置”的弹窗,请选用其他方法查看消费位点。

图8 恢复配置入口

图9 恢复配置

根据作业WAL抽取时延估算已消费位点

运行中的作业,查看监控信息,然后跳转“查看监控指标”,查看最近的一次时延上报情况。

图10 查看监控指标

如下图,2025-07-29 16:14:40的时候,时延处于毫秒级,可以认为作业没有时延,已消费位点可以粗略估计为“2025-07-29 16:10:00”,这里估测位点时往前回退几分钟更为安全,应尽量保证作业不丢数。

图11 查看作业时间

相关文档