有没有好用的达梦 CDC 相关的组件呢?需要使用到 Flink SQL 中
DM8 Flink CDC连接器
DM8 Flink CDC连接器是基于Flink框架开发的,用于对DM8数据进行实时采集。该连接器通过使用DM提供的DBMS_LOGMNR包对归档日志进行挖掘,并采用已有的解析工具对SQL进行解析,重构出DDL和DML操作,将结构化的数据下发给下游消费。此外,DM8 Flink CDC连接器已适配Flink SQL,用户可以通过纯SQL的方式开发和运行Flink数据同步任务,也可以编写代码将Table-api转为Stream-api,并对流式数据消息进行自定义处理。