Re:RE: 如何基于flink cdc 3.x自定义不基于debezium的全增量一体source connector？

Sun, 21 Jan 2024 18:58:53 -0800 








Flink CDC MongoDB connector 还是基于debezium实现的








在 2024-01-22 10:14:32，"Jiabao Sun" <jiabao....@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示例？谢谢！






















					回复