flink1.14.6 + cdc2.3.0 在debezium-connector-mysql-?[阿里云实时计算 Flink版]

flink1.14.6 + cdc2.3.0 在debezium-connector-mysql-1.6.4.Final.jar和flink-connector-mysql-cdc-2.3.0.jar中同时存在io.debezium.connector.mysql.MySqlConnection$MySqlConnectionConfiguration但构造方法不同,参考https://github.com/ververica/flink-cdc-connectors/pull/1217?![image.png](https://www.tongchenyun.com/wp-content/uploads/aliyun/2023/1128/wyvq5mjsckydw_7cfe0967ee2f4fbbaa0e1e9666e4f4b2.png)

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 您可能在使用 Flink 1.14.6 和 Flink CDC 2.3.0 版本,同时使用 Debezium Connector for MySQL。Debezium Connector for MySQL 是 Flink CDC 的一个子连接器,用于抓取 MySQL 数据库的增量数据。

    如果您在使用 Debezium Connector for MySQL 时遇到了问题,可以尝试检查连接器的配置和日志,确定连接器是否正确启动和工作。同时,您还可以参考 Flink 官方文档和 Debezium 官方文档中的相关章节,了解如何正确配置和使用 Debezium Connector for MySQL。

  2. 根据您提供的信息,您在使用 Flink 1.14.6 和 CDC 2.3.0 版本时遇到了 io.debezium.connector.mysql.MySqlConnection$MySqlConnectionConfiguration 的构造方法不同的问题。具体表现为在 debezium-connector-mysql-1.6.4.Final.jar 和 flink-connector-mysql-cdc-2.3.0.jar 中同时存在相同的类但构造方法不同。

    根据您提供的链接,这个问题可能是由于版本兼容性或依赖冲突引起的。在该链接中,已经有相关的 Pull Request(PR)提交,旨在解决这个问题。

    以下是一些可能的解决方案:

    1. 使用修复补丁:如果您需要尽快解决此问题,您可以尝试使用该 PR 中提供的修复补丁,以解决构造方法不同的问题。您可以手动将修改后的代码应用到相关的库中,并重新编译和部署 Flink CDC 应用程序。

    2. 更新依赖版本:尝试更新 debezium-connector-mysql 和 flink-connector-mysql-cdc 的版本,以确保它们兼容并且没有相同的类但构造方法不同的问题。查看发布的新版本是否解决了这个问题,并将其应用到您的项目中。

    3. 向 Flink CDC 社区寻求帮助:如果以上解决方案无法解决问题,建议向 Flink CDC 的官方社区寻求帮助。可以通过邮件列表、社区论坛或 GitHub 提交问题报告,将您遇到的具体错误信息和配置细节提供给社区成员,以便他们能够更好地理解和诊断您的问题。