在 MySQL CDC 任务中，很多用户都会遇到这样的问题：任务失败后该从哪里恢复？只知道一个时间点，却拿不到对应的 binlog 位点怎么办？Apache SeaTunnel
本文围绕该能力的设计背景、配置方式与实现机制展开解析，帮助读者理解如何基于时间语义更高效地进行 CDC 任务恢复与数据回溯。
Problem：CDC 启动点配置“技术正确，但使用困难” 在 Apache SeaTunnel 2.3.12 之前，MySQL CDC 连接器主要支持从 指定 binlog 位点（file + position）或 GTID 启动数据同步任务。这种方式在实现上是精确且可靠的，但在真实生产与运维场景中，往往并不符合用户的使用习惯。
在实际 CDC 运维过程中，用户更容易掌握的是 “时间” ，而非底层 binlog 细节，例如：
任务异常中断后，希望从 “2024-04-01 10:00:00” 之后继续同步 只知道“昨天 08:00 之后的变更需要重新同步”，但无法定位对应的 binlog 文件和偏移量 如果仍要求用户手动将时间反推为 binlog 位点，不仅配置复杂，而且极易出错，也显著增加了运维成本。这种“技术友好、但用户不友好”的启动方式，已经成为 CDC 任务恢复和回溯场景中的常见痛点。
Solution：引入按时间启动 为解决上述问题，Apache SeaTunnel 在 2.3.12 版本 中为 MySQL CDC 连接器引入了 按时间启动功能 。
该功能允许用户直接指定一个 Unix 时间戳（毫秒级） 作为同步起始点。MySQL CDC 连接器会在启动阶段自动完成以下工作：
根据指定时间戳定位对应的 binlog 文件与偏移量 通过引入“时间”这一更符合业务语义的维度，SeaTunnel 将 CDC 启动方式从 面向底层 binlog 细节 ，提升为 面向业务时间语义 ，显著降低了 CDC 任务在 恢复、回溯和运维场景 下的使用门槛。
要启用按时间启动功能，需要配置以下两个关键参数：
startup.mode startup.timestamp
env { parallelism = 1 job.mode = "STREAMING" checkpoint.interval = 10000}source { MySQL-CDC { url = "jdbc:mysql://localhost:3306/testdb" username = "root" password = "root@123" table-names = ["testdb.table1"] # 启用按时间启动 startup.mode = "timestamp" startup.timestamp = 1672531200000 # 2023-01-01 00:00:00 UTC }}sink { Console { }} 启动模式枚举 在 MySqlSourceOptions 类中定义了所有支持的启动模式，包括新增的 TIMESTAMP 模式：
public static final SingleChoiceOption<StartupMode> STARTUP_MODE = (SingleChoiceOption) Options.key(SourceOptions.STARTUP_MODE_KEY) .singleChoice( StartupMode.class, Arrays.asList( StartupMode.INITIAL, StartupMode.EARLIEST, StartupMode.LATEST, StartupMode.SPECIFIC, StartupMode.TIMESTAMP)) 时间戳过滤实现 核心实现在 MySqlBinlogFetchTask 类中，当检测到启动模式为 TIMESTAMP 时，会使用 TimestampFilterMySqlStreamingChangeEventSource 来处理 binlog 事件：
StartupMode startupMode = startupConfig.getStartupMode();if (startupMode.equals(StartupMode.TIMESTAMP)) { log.info( "Starting MySQL binlog reader,with timestamp filter {}", startupConfig.getTimestamp()); mySqlStreamingChangeEventSource = new TimestampFilterMySqlStreamingChangeEventSource( sourceFetchContext.getDbzConnectorConfig(), sourceFetchContext.getConnection(), sourceFetchContext.getDispatcher(), sourceFetchContext.getErrorHandler(), Clock.SYSTEM, sourceFetchContext.getTaskContext(), sourceFetchContext.getStreamingChangeEventSourceMetrics(), startupConfig.getTimestamp());} 偏移量计算 在 MySqlSourceFetchTaskContext 中实现了根据时间戳查找对应 binlog 偏移量的逻辑：
private Offset getInitOffset(SourceSplitBase mySqlSplit) { StartupMode startupMode = getSourceConfig().getStartupConfig().getStartupMode(); if (startupMode.equals(StartupMode.TIMESTAMP)) { long timestamp = getSourceConfig().getStartupConfig().getTimestamp(); try (JdbcConnection jdbcConnection = getDataSourceDialect().openJdbcConnection(getSourceConfig())) { return findBinlogOffsetBytimestamp(jdbcConnection, binaryLogClient, timestamp); } catch (Exception e) { throw new SeaTunnelException(e); } } else { return mySqlSplit.asIncrementalSplit().getStartupOffset(); }} 为了更好地理解按时间启动功能在整体 CDC 启动体系中的定位，下面对 MySQL CDC 当前支持的几种启动模式进行对比说明：
INITIAL EARLIEST LATEST SPECIFIC 指定 binlog file + position TIMESTAMP 任务恢复、数据回溯、按时间窗口同步
可以看到， TIMESTAMP 模式并不是替代 SPECIFIC 或 GTID 的“更底层”方案 ，而是为了解决“用户只知道时间、不知道 binlog”的典型问题，是一种 以可用性和运维友好性为核心的补充能力 。
该功能在集成测试中得到了充分验证，测试用例 MysqlCDCSpecificStartingOffsetIT 验证了按时间戳启动的正确性 7 。
版本要求： 需要 SeaTunnel 2.3.12 或更高版本
时间戳格式： 必须使用 Unix 时间戳，单位为毫秒
binlog 可用性： 确保指定时间点对应的 binlog 文件仍然可用
时区考虑 ：时间戳基于 UTC 时区，需要注意时区转换
该功能在工厂类MySqlIncrementalSourceFactory中通过条件配置规则进行参数验证 除了 MySQL CDC，其他 CDC 连接器如 SQL Server CDC 也支持类似的时间戳启动功能 SeaTunnel MySQL CDC 的按时间启动功能为数据同步提供了更精确的控制能力，特别适用于需要从特定时间点恢复数据同步的场景。该功能通过时间戳到 binlog 偏移量的转换，实现了高效的时间点定位和数据过滤。
Apache SeaTunnel Apache SeaTunnel是一个云原生的多模态、高性能海量数据集成工具。北京时间 2023 年 6 月1 日，全球最大的开源软件基金会ApacheSoftware Foundation正式宣布Apache SeaTunnel毕业成为Apache顶级项目。目前，SeaTunnel在GitHub上Star数量已达8k+，社区达到6000+人规模。SeaTunnel支持在云数据库、本地数据源、SaaS、大模型等170多种数据源之间进行数据实时和批量同步，支持CDC、DDL变更、整库同步等功能，更是可以和大模型打通，让大模型链接企业内部的数据。
https://github.com/apache/seatunnel https://seatunnel.apache.org/ https://seatunnel.apache.org/download 我们相信，在 「 Community Over Code 」 （社区大于代码）、 「Open and Cooperation」 （开放协作）、 「Meritocracy」 （精英管理）、以及「 多样性与共识决策」 等 The Apache Way 的指引下，我们将迎来更加多元化和包容的社区生态，共建开源精神带来的技术进步！ 我们诚邀各位有志于让本土开源立足全球的伙伴加入 SeaTunnel 贡献者大家庭，一起共建开源! https://github.com/apache/seatunnel/issues https://github.com/apache/seatunnel/pulls dev-subscribe@seatunnel.apache.org https://join.slack.com/t/apacheseatunnel/shared_invite/zt-1kcxzyrxz-lKcF3BAyzHEmpcc4OSaCjQ https://x.com/ASFSeaTunnel
