实时计算Flink版的MySQLCDC如何从指定位点读取数据
已解决实时计算Flink版的MySQLCDC如何从指定位点读取数据
展开
收起
1
条回答
写回答
写回答
-
开发者社区问答官方账号官方回答采纳回答Flink暂时不支持作业启动弹框时配置启动位点来读取数据。仅可通过scan.startup.mode指定MySQL CDC源表的启动模式，可选值包括：- initial （默认）：在第一次启动时，会先扫描历史全量数据，然后读取最新的Binlog数据。
- earliest-offset：在第一次启动时，不会扫描历史全量数据，直接从Binlog的末尾（最新的Binlog处）开始读取，即只读取该Connector启动以后的最新变更。
- latest-offset：不扫描历史全量数据，直接从可读取的最早Binlog开始读取。
- specific-offset：不扫描历史全量数据，从您指定的Binlog位点启动，位点可通过配置scan.startup.specific-offset.file和scan.startup.specific-offset.pos的方式来指定从特定Binlog文件名和偏移量启动，也可以通过配置scan.startup.specific-offset.gtid-set指定从某个GTID集合启动。
- timestamp：跳过快照阶段，从指定的时间戳开始读取Binlog事件。时间戳通过scan.startup.timestamp-millis指定，单位为毫秒。注意，在读到该时间戳之前flink任务会一直无数据输出
2024-06-08 19:07:08赞同 1 展开评论 打赏
问答分类：
关联地址：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
