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

Flink CDC有没有考虑升级dbz版本?我看dbz2+版本是java11写的?

Flink CDC有没有考虑升级dbz版本?我看dbz2+版本是java11写的?

展开
收起
cuicuicuic 2023-11-01 14:35:31 60 0
3 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    确实,Debezium 版本不同会影响兼容性,可以在 Flink 官方文档中查看支持的 debezium 版本。如果要升级 DBZ 版本,您需要注意版本之间的兼容性问题。一般来说,最新版的 Debezium 版本对应的是 Java 8 或更高版本,请慎重选择对应的 Java 版本。
    另外,请确保您有足够的 RAM 和 CPU 资源来处理任务,否则会影响到 Debezium 的性能。

    2023-11-02 15:04:11
    赞同 展开评论 打赏
  • Flink CDC 是一个基于 Debezium 的分布式数据同步组件,它将 Kafka Connect API 与 Flink 集成在一起,实现了基于 Flink 的数据流处理和状态管理。Debezium 版本与 Flink CDC 的版本之间存在一定的关联,但它们是两个独立的组件,Flink CDC 的升级并不一定会考虑到 Debezium 的版本升级。

    Debezium 是一个分布式、事件驱动的数据同步平台,它基于 Kafka 和数据库连接器来实现数据捕获和同步。Debezium 的版本升级会修复一些已知的问题,增加一些新的特性,但升级过程中可能涉及到一些兼容性问题或者对现有功能的影响。

    关于您提到的 Debezium 2+ 版本是用 Java 11 编写的,这是正确的。Debezium 2.x 系列版本是使用 Java 11 进行开发的,而之前的版本是基于 Java 8 开发的。使用 Java 11 可以获得更好的语言特性和性能优化,同时也会有一些新的库和工具可用。

    如果您考虑升级 Debezium 版本,建议您先仔细评估升级的利弊,并进行充分的测试。如果您正在使用 Flink CDC,并且需要升级 Debezium 版本,您需要了解升级过程中可能对您的 Flink CDC 作业产生的影响,并相应地调整您的 Flink CDC 配置和代码。

    2023-11-02 14:46:33
    赞同 展开评论 打赏
  • 小版本是不会升级dbz的版本的,只有大版本才有,目前2.5的roadmap没有这个计划,此回答整理自钉群“Flink CDC 社区”

    2023-11-01 21:40:18
    赞同 展开评论 打赏

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

相关产品

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

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