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

Flink CDC里请问哪个版本支持row_kind元数据?

Flink CDC里请问哪个版本支持row_kind元数据?

展开
收起
小小鹿鹿鹿 2024-02-26 17:10:45 167 0
1 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink CDC 3.0版本开始支持row_kind元数据

    Flink CDC(Change Data Capture)是一个用于捕获数据库变更的库,它允许用户实时地获取和处理数据变更流。在早期版本中,Flink CDC 对于MySQL CDC连接器只声明了table_name、database_name、op_ts这些元数据列。从3.0版本开始,Flink CDC新增了对row_kind元数据列的支持,这使得在处理流表数据时能够更加方便。

    具体来说,row_kind元数据列的作用是标识每条记录的变更类型,比如插入、更新或删除。这个信息对于理解和处理数据变更非常重要,尤其是在进行复杂的数据处理和转换操作时。在3.0版本之前,如果用户需要这些信息,可能需要通过其他方式来推断或获取。

    此外,Flink CDC 2.x版本虽然不支持row_kind元数据列,但它兼容Flink 1.13和Flink 1.14两个大版本,并且在这个版本中,Flink CDC已经支持了多达12种不同的数据源接入,包括OceanBase、PolarDB-X、SqlServer、TiDB等。

    综上所述,如果您需要在Flink CDC中使用row_kind元数据列,建议升级到最新的3.0版本。这将为数据处理带来便利,同时也能享受到Flink CDC在数据同步方面的最新改进和优化。

    2024-02-27 13:28:06
    赞同 展开评论 打赏

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

相关产品

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

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