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

请问下,Flink CDC 中debezium1.6之后开始依赖JDK11,flink是怎么做到?

请问下,Flink CDC 中debezium1.6之后开始依赖JDK11,flink是怎么做到debezium1.9.7.Final在JDK8下也能使用的

展开
收起
真的很搞笑 2023-07-02 16:49:56 147 0
3 条回答
写回答
取消 提交回答
  • Flink CDC 使用的是 Debezium Connectors 的源码,但并不直接依赖于 Debezium。相反,Flink CDC 将 Debezium Connectors 进行了重构,并移植到 Flink Connectors API 中。因此,Flink CDC 本身可以兼容较低版本的 Flink。

    具体来说:

    1. Debezium 1.6+ 版本开始要求使用 JDK 11。 2. 但是 Flink CDC 并没有直接依赖 Debezium,而是将 Debezium Connectors 源码移植到 Flink Connectors API 中。 3. 因此,Flink CDC 可以兼容较低版本的 Flink,只需要满足当前使用的 Flink 版本即可。 4. Flink CDC 定期与 Debezium 同步源码,并保持与自身 Flink 版本的兼容性要求。

    举个例子来说明:

    - Debezium 1.6 需要 JDK 11。 - 但是 Flink CDC 2.4.0(当前稳定版本)仍然可以与 Flink 1.14.2(支持 JDK 8)兼容。 - 这是因为 Flink CDC 并不直接使用 Debezium 的 JAR 包,而是基于 Debezium Connector 的源码实现的。

    综上所述,Flink CDC 可以独立于 Debezium 对 JDK 的要求,只需要满足自身所依赖的 Flink 版本的要求即可。

    2023-07-30 12:56:12
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    Flink CDC 使用 Debezium Connectors 作为源码,但并非直接依赖 Debezium。
    Flink CDC 将 Debezium Connectors 重构并移植到 Flink Connectors API 中,因此 Flink CDC 本身依旧可以兼容低版本的 Flink。
    具体来说:
    Debezium 1.6+ 已经开始需要 JDK 11
    但 Flink CDC 并没有直接依赖 Debezium,而是基于 Debezium Connector 源码,移植到 Flink Connectors API 中
    所以 Flink CDC 可以兼容低版本的 Flink(支持 JDK 8),只要 Flink 当前版本支持即可
    Flink CDC 会定期与 Debezium 同步源码,并保持兼容本身的 Flink 版本要求
    举个例子:
    Debezium 1.6 需要 JDK 11
    但 Flink CDC 2.4.0(当前稳定版)依然可以与 Flink 1.14.2(支持 JDK 8)兼容
    这是因为 Flink CDC 并没有直接使用 Debezium Jar 包,而是基于 Debezium Connector 源码实现的。
    所以总的来说,Flink CDC 可以独立于 Debezium 的 JDK 要求,只要兼容本身 Flink 版本即可。
    希望以上解释能为你提供参考!如

    2023-07-30 10:50:20
    赞同 展开评论 打赏
  • https://www.morling.dev/blog/bytebuffer-and-the-dreaded-nosuchmethoderror/,11编译的,但是好像还支持在1.8上运行。,此回答整理自钉群“Flink CDC 社区”

    2023-07-02 17:05:28
    赞同 展开评论 打赏

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

相关产品

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

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载