建站
咨詢
售后
建站咨詢
新聞中心
需要引入 Flink CDC 的 jar 包，可以在 Maven 倉庫中搜索 flink-connector-debezium 或 flink-connector-mysql-cdc。
在Flink CDC中，如果找不到某個包，需要引入相應的jar文件，以下是一些常見的Flink CDC相關包及其對應的jar文件：
成都創(chuàng)新互聯(lián)公司10多年企業(yè)網(wǎng)站設計服務;為您提供網(wǎng)站建設,網(wǎng)站制作,網(wǎng)頁設計及高端網(wǎng)站定制服務,企業(yè)網(wǎng)站設計及推廣,對成都葡萄架等多個方面擁有多年的網(wǎng)站維護經(jīng)驗的網(wǎng)站建設公司。
1、Flink CDC Connectors
引入的jar文件：flinkconnectordebezium_2.11.jar（對于Scala 2.11版本）或flinkconnectordebezium_2.12.jar（對于Scala 2.12版本）
2、Flink CDC Sources
引入的jar文件：根據(jù)具體的CDC源類型而定，
flinkconnectorkafka_2.11.jar（對于Scala 2.11版本）或flinkconnectorkafka_2.12.jar（對于Scala 2.12版本）用于Kafka CDC源
flinkconnectormysqlcdc_2.11.jar（對于Scala 2.11版本）或flinkconnectormysqlcdc_2.12.jar（對于Scala 2.12版本）用于MySQL CDC源
flinkconnectorpostgres_2.11.jar（對于Scala 2.11版本）或flinkconnectorpostgres_2.12.jar（對于Scala 2.12版本）用于PostgreSQL CDC源
3、Flink CDC Sinks
引入的jar文件：根據(jù)具體的CDC目標類型而定，
flinkconnectorkafka_2.11.jar（對于Scala 2.11版本）或flinkconnectorkafka_2.12.jar（對于Scala 2.12版本）用于Kafka CDC目標
flinkconnectorjdbc_2.11.jar（對于Scala 2.11版本）或flinkconnectorjdbc_2.12.jar（對于Scala 2.12版本）用于JDBC CDC目標
請注意，上述提到的jar文件是針對Flink 1.x版本的，如果你使用的是Flink 2.x或更高版本，可能需要使用不同的jar文件，還需要確保你的項目已經(jīng)正確配置了Maven或Gradle等構建工具，以便能夠自動下載和引入所需的依賴項。
文章題目：FlinkCDC里這個包一直找不到，需要引入哪個jar？
網(wǎng)頁路徑：http://www.5511xx.com/article/cdgdphs.html
