日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
FlinkCDC里這個(gè)包一直找不到,需要引入哪個(gè)jar?
需要引入 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