Flink CDC MySQL DataStream API 问题：版本不匹配和 JAR 包依赖问题怎么解决？

flinkcdc mysql DataStream API 问题解析

根据描述的代码和问题，可能存在以下问题：

1. 版本不匹配：

   • flink 的版本（1.15.1）与使用的 Flink CDC 声明的版本（2.1.1）不匹配。应该使用与 Flink CDC 相对应的 Flink 版本，即 1.13.6。

2. 相关 JAR 包不对应：

   • 除了驱动程序之外，Flink CDC 所依赖的 JAR 包的版本也需要与声明的版本一致。因此，应该将 IDE 中依赖的非 Flink JAR 包（例如阿里巴巴的 FastJSON）复制到 Flink 的 lib 目录（%FLINK_HOME%/lib）中，并确保版本与 Flink CDC 需要的版本相符。

修复以上问题后，代码才能正常运行。

以上就是Flink CDC MySQL DataStream API 问题：版本不匹配和 JAR 包依赖问题怎么解决？的详细内容，更多请关注其它相关文章！