flinkcdc
写了一个flinkcdc的简单demo，大概说一下实现过程和建议点
架构图大致如下： 版本信息大致如下，具体版本信息根据自己的需求进行调整即可： oracle：19c flinkcdc：2.4.0 kafka：3.1.2 flink：1.15.4 mysql：8.0.27 springboot：2.5.6 实现需求： 1.使用flinkcdc采集oracle中的数据 ......
flinkcdc连接oracle的报错汇总
报错一： 原因分析：字面原因，找不到 org.apache.flink.table.api.ValidationException类。 解决办法：根据类名可知，应该 org.apache.flink.table.api 包下面的，然后去阿里云maven仓库搜索，添加如下依赖即可 报错二： 原因分析： ......
chatpgt-flinkcdc从mysql到kafka再到mysql
flinkcdc mysql到kafka import org.apache.flink.api.common.serialization.SimpleStringSchema; import org.apache.flink.streaming.api.environment.StreamExec ......