hello  我现在碰到一个问题  在使用flink
cdc同步数据时我设置了snapshot.mode的值为schema_only,但是当我重启任务时发现都是从最新开始消费,我该怎么做才能从上次停止任务的断点继续消费;同时我使用MySQLSource.<String>builder().serverId(123456)的方式设置了server_id,但是从打印出来的数据来看并没有生效



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复