You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 奔跑的小飞袁 <s_...@126.com> on 2021/02/05 09:44:44 UTC

flink cdc同步数据

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



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