开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink-connector-mysql-cdc-2.3.0.jar中都有相同路径的?

看了下jar信息 flink-connector-mysql-cdc-2.3.0.jar和debezium-connector-mysql-1.6.4.Final.jar中都有相同路径的io.debezium.connector.mysql.MySqlConnection?image.png

展开
收起
真的很搞笑 2023-08-28 15:30:40 101 0
1 条回答
写回答
取消 提交回答
  • 在 Flink CDC 的 MySQL Connector(flink-connector-mysql-cdc-2.3.0.jar)和 Debezium 的 MySQL Connector(debezium-connector-mysql-1.6.4.Final.jar)中,可能会存在相同的路径 io.debezium.connector.mysql.MySqlConnection。

    这是因为 Flink CDC 的 MySQL Connector 实际上是基于 Debezium 的 MySQL Connector 进行开发和扩展的。Flink CDC 通过集成 Debezium 同步引擎来实现 MySQL 数据库的变更捕获功能。

    在 Flink CDC 中,flink-connector-mysql-cdc-2.3.0.jar 作为 Flink Connector 的扩展,它可能包含了一些自定义的实现或修改,以适应 Flink 的运行时环境和 CDC 功能。

    因此,你会看到 Flink CDC 的 MySQL Connector 和 Debezium 的 MySQL Connector 中都有相同路径的类。但是,它们可能有不同的实现细节和用法,以满足各自不同的需求和功能。

    需要注意的是,在使用 Flink CDC 时,你应该使用 Flink CDC 版本提供的 Connector JAR 文件(flink-connector-mysql-cdc-2.3.0.jar),而不是直接使用 Debezium 的 Connector JAR 文件(debezium-connector-mysql-1.6.4.Final.jar)。

    如果你需要更深入地了解 Flink CDC 的 MySQL Connector 的实现和用法,建议查阅 Flink CDC 的官方文档和源代码,或者向 Flink 社区寻求帮助和支持。

    2023-09-18 18:04:56
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    One Box: 解读事务与分析一体化数据库 HybridDB for MySQL 立即下载
    One Box:解读事务与分析一体化数据库HybridDB for MySQL 立即下载
    如何支撑HTAP场景-HybridDB for MySQL系统架构和技术演进 立即下载

    相关镜像