報錯 java.lang.NoClassDefFoundError: org/apache/flink/shaded/guava18/com/google/common/util/concurrent/ThreadFactoryBuilder
flink cdc 2.2.1源碼依賴flink1.13.5
如果使用flink1.14版本，則會缺少依賴org.apache.flink:flink-shaded-guava:18.0-13.0
添加依賴org.apache.flink:flink-shaded-guava:18.0-13.0

<dependency><groupId>com.ververica</groupId><artifactId>flink-connector-mysql-cdc</artifactId><version>2.2.1</version><exclusions><exclusion><artifactId>flink-shaded-guava</artifactId><groupId>org.apache.flink</groupId></exclusion></exclusions></dependency>

或者手動添加flink-shaded-guava:18.0-13.0到依賴庫

無法執行初始化
啟動模式使用StartupOptions.initial()無法初始化數據
相較1.x版本，2.x開發測試時需要額外添加依賴flink-table-common

報錯 java.lang.NoSuchMethodError: com.mysql.cj.CharsetMapping.getJavaEncodingForMysqlCharset

總結

以上是生活随笔為你收集整理的flink cdc 2.2.1 mysql connector的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。