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 需要的版本相符。

修復以上問題后，代碼才能正常運行。