GoForum › 🌐 V2EX

mysql to doris. flink-cdc 怎么重新启动时续传，而不是从 0 开始

qbmiller · 2026-01-13 12:18 · 0 次点赞 · 1 条回复

bash bin/flink-cdc.sh mysql-to-doris.yaml

https://i.imgur.com/4QJyYe9.png flink 配置如下，最后生效的是 execution_checkpointing https://i.imgur.com/u6dwjN0.png

1 条回复

AlexRoot · 2026-01-13 12:53

从 checkpoint 中恢复，checkpoint 中有上次你消费的 kafka binlog offset, 或者是已经分好的 snapshot split.。

添加回复

你还需要登录后发表回复

登录后可发帖和回复

登录注册

主题信息

作者: qbmiller

发布: 2026-01-13

点赞: 0

回复: 0

mysql to doris. flink-cdc 怎么重新启动时 续传，而不是从 0 开始