flink1.14.6 + cdc2.3.0 在debezium-connector-mysql-？

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://ucc.alicdn.com/pic/developer-ecology/wyvq5mjsckydw_7cfe0967ee2f4fbbaa0e1e9666e4f4b2.png)

展开

收起

真的很搞笑 2023-07-13 11:54:16 128 0

2 条回答

写回答

取消提交回答

算精通

北京阿里云ACE会长

您可能在使用 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。

2023-07-30 09:37:20

赞同展开评论打赏
Star时光

根据您提供的信息，您在使用 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 提交问题报告，将您遇到的具体错误信息和配置细节提供给社区成员，以便他们能够更好地理解和诊断您的问题。

2023-07-29 22:45:02

赞同展开评论打赏