FlinkCDC里这个包一直找不到，需要引入哪个jar？

需要引入 Flink CDC 的 jar 包，可以在 Maven 仓库中搜索 flink-connector-debezium 或 flink-connector-mysql-cdc。

在Flink CDC中，如果找不到某个包，需要引入相应的jar文件，以下是一些常见的Flink CDC相关包及其对应的jar文件：

成都创新互联公司10多年企业网站设计服务;为您提供网站建设,网站制作,网页设计及高端网站定制服务,企业网站设计及推广,对成都葡萄架等多个方面拥有多年的网站维护经验的网站建设公司。

1、Flink CDC Connectors

引入的jar文件：flinkconnectordebezium_2.11.jar（对于Scala 2.11版本）或flinkconnectordebezium_2.12.jar（对于Scala 2.12版本）

2、Flink CDC Sources

引入的jar文件：根据具体的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文件：根据具体的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文件，还需要确保你的项目已经正确配置了Maven或Gradle等构建工具，以便能够自动下载和引入所需的依赖项。

当前标题：FlinkCDC里这个包一直找不到，需要引入哪个jar？
文章地址：http://www.shufengxianlan.com/qtweb/news36/402936.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联