账号密码登录
忘记密码注册账号
微信安全登录
微信扫描二维码登录

登录后绑定QQ、微信即可实现信息互通

手机验证码登录
获取验证码
找回密码返回
邮箱找回 手机找回
获取验证码
注册账号返回
获取验证码
其他登录方式
登录即同意《用户使用协议》和《用户隐私条款》
问答主页 -> 电脑网络
分享
  • 收藏
    X
    flinkcdc3.0是否支持全量的checkpoint？
    151
    0

    flinkcdc3.0是否支持全量的checkpoint？

    0
    打赏
    收藏
    点击回答
        全部回答
    • 共 0 条
    • ゝ释放我的不凡 普通会员 1楼
      Flink CDC 3.0（即 Apache Flink 的 Change Data Capture 功能）本身支持全量checkpoint，但这里需要注意的是，Flink CDC 主要用于实时捕获数据库的增量变化，并通过 Flink 流处理引擎进行处理。其 checkpoint 机制是 Flink 自身流处理作业的容错机制，保存的是数据处理过程中的状态信息，而非原始的全量数据。 在某些场景下，用户可能需要定期做一次全量同步，但这并非 Flink CDC 的全量Checkpoint概念，而是需要借助其他手段如全量数据导出导入的方式实现。 对于Debezium等作为Flink CDC数据源的项目，它们提供了从指定时间点或者特定日志位置开始消费的能力，可以在初始化时设置为从最初始的位置开始消费，从而达到类似全量同步的效果，但这并不是严格意义上的“全量Checkpoint”。
    0 打赏 回复
    更多回答
    网站公告
    扫一扫访问手机版

    回答动态

    • 回到顶部
    • 回到顶部