Flink CDC 如何从指定位置拉取消息

Posted 2021-12-04 北鹤M

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink CDC 如何从指定位置拉取消息相关的知识，希望对你有一定的参考价值。

场景

已知binlog的文件名和pow编号，希望从指定的位置拉消息

在连接的时候加上这句

.startupOptions(StartupOptions.specificOffset("mysql-bin.000013", 1260))

以上是关于Flink CDC 如何从指定位置拉取消息的主要内容，如果未能解决你的问题，请参考以下文章