Hi, Flink CDC MongoDB connector V1是基于 mongo-kafka 实现的，没有基于 debezium 实现。 Flink CDC MongoDB connector V2是基于增量快照读框架实现的，不依赖 mongo-kafka 和 debezium 。
Best, Jiabao [1] https://github.com/mongodb/mongo-kafka On 2024/01/22 02:57:38 "casel.chen" wrote: > > > > > > > > > > Flink CDC MongoDB connector 还是基于debezium实现的 > > > > > > > > > 在 2024-01-22 10:14:32，"Jiabao Sun" <ji...@xtransfer.cn.INVALID> 写道： > >Hi, > > > >可以参考 Flink CDC MongoDB connector 的实现。 > > > >Best, > >Jiabao > > > > > >On 2024/01/22 02:06:37 "casel.chen" wrote: > >> 现有一种数据源不在debezium支持范围内，需要通过flink sql全增量一体消费，想着基于flink cdc > >> 3.x自行开发，查了一下现有大部分flink cdc source > >> connector都是基于debezium库开发的，只有oceanbase和tidb不是，但后二者用的source接口还是V1版本的，不是最新V2版本的incremental > >> snapshot，意味着全量阶段不支持checkpoint，如果作业失败需要重新从头消费。 > >> 想问一下有没有不基于debezium实现的V2版本source connector示例？谢谢！ >
