flink cdc 同步数据问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink cdc 同步数据问题

奔跑的小飞袁
hello  我想问一下使用flink
cdc同步数据是设置了snapshot.mode这个参数为schema_only,但是我发现每次重启任务都会从最新开始读取数据,我怎么做才可以从上次断点继续消费呢;同时我通过MySQLSource.<String>builder().serverId(123456)的方式设置了server_id但是从我同步出来的数据来看server_id并不是我设置的值



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