各位大佬 请教一下 flink 1.7.0 集成 cdc 有没有大佬遇到过？
各位大佬 请教一下 flink 1.7.0 集成 cdc flink-connector-sqlserver-cdc（中央仓库 2.3.0） 提示 Caused by: java.lang.AbstractMethodError: com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore.get(Ljava/util/Collection;Lorg/apache/kafka/connect/util/Callback;)Ljava/util/concurrent/Future;
有没有大佬遇到过？
写回答
-
报错信息 "Caused by: java.lang.AbstractMethodError: com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore.get(Ljava/util/Collection;Lorg/apache/kafka/connect/util/Callback;)Ljava/util/concurrent/Future" 表示你正在使用的版本组合不兼容。这个问题通常是因为 Flink CDC Connector 和 Flink 版本之间存在不匹配的情况。
根据你提供的信息，你正在使用 Flink 1.7.0 和 Flink CDC Connector 2.3.0。然而，Flink CDC Connector 2.3.0 是为更高版本的 Flink（例如 Flink 1.11.x）设计的，与 Flink 1.7.0 不兼容，因此导致了该错误。
解决这个问题的方法是：
升级 Flink 版本：将 Flink 升级到与 Flink CDC Connector 2.3.0 兼容的版本（例如 Flink 1.11.x）。然后，确保使用与所选 Flink 版本对应的 Flink CDC Connector。
降级 Flink CDC Connector 版本：如果你必须使用 Flink 1.7.0 版本，那么你需要使用与该版本兼容的 Flink CDC Connector。请检查 Flink CDC Connector 的文档或查找与 Flink 1.7.0 兼容的版本。
请注意，确保 Flink CDC Connector 与所使用的 Flink 版本完全兼容非常重要，以避免出现不匹配和类似的错误。
2023-09-27 18:27:01赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
