新聞中心
需要引入 Flink CDC 的 jar 包,可以在 Maven 倉庫中搜索 flink-connector-debezium 或 flink-connector-mysql-cdc。
在Flink CDC中,如果找不到某個(gè)包,需要引入相應(yīng)的jar文件,以下是一些常見的Flink CDC相關(guān)包及其對應(yīng)的jar文件:

成都創(chuàng)新互聯(lián)公司10多年企業(yè)網(wǎng)站設(shè)計(jì)服務(wù);為您提供網(wǎng)站建設(shè),網(wǎng)站制作,網(wǎng)頁設(shè)計(jì)及高端網(wǎng)站定制服務(wù),企業(yè)網(wǎng)站設(shè)計(jì)及推廣,對成都葡萄架等多個(gè)方面擁有多年的網(wǎng)站維護(hù)經(jīng)驗(yàn)的網(wǎng)站建設(shè)公司。
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目標(biāo)類型而定,
flinkconnectorkafka_2.11.jar(對于Scala 2.11版本)或flinkconnectorkafka_2.12.jar(對于Scala 2.12版本)用于Kafka CDC目標(biāo)
flinkconnectorjdbc_2.11.jar(對于Scala 2.11版本)或flinkconnectorjdbc_2.12.jar(對于Scala 2.12版本)用于JDBC CDC目標(biāo)
請注意,上述提到的jar文件是針對Flink 1.x版本的,如果你使用的是Flink 2.x或更高版本,可能需要使用不同的jar文件,還需要確保你的項(xiàng)目已經(jīng)正確配置了Maven或Gradle等構(gòu)建工具,以便能夠自動(dòng)下載和引入所需的依賴項(xiàng)。
文章題目:FlinkCDC里這個(gè)包一直找不到,需要引入哪個(gè)jar?
網(wǎng)址分享:http://www.dlmjj.cn/article/cdgdphs.html


咨詢
建站咨詢
