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

Flink CDC release-2.4.0支持对OceanBase Oracle 模式做CD吗?

Flink CDC中 release-2.4.0 支持对OceanBase Oracle 模式做CDC么?

展开
收起
十一0204 2023-07-26 08:04:11 112 0
3 条回答
写回答
取消 提交回答
  • 根据 Flink CDC 的官方文档,截至目前(2021年12月),Flink CDC 尚不支持直接对 OceanBase Oracle 模式进行 Change Data Capture(CDC)操作。

    Flink CDC 目前主要支持以下几个数据库的 CDC:

    • MySQL
    • PostgreSQL
    • Oracle
    • SQL Server

    虽然 OceanBase 是一个基于分布式架构的关系型数据库,与 Oracle 存在一些相似之处,但由于其内部结构和协议的差异,Flink CDC 还未提供专门支持 OceanBase Oracle 模式的功能。

    如果你希望在 Flink 中实现对 OceanBase Oracle 模式的 CDC 操作,可能需要自行开发或寻找第三方工具来实现。你可以考虑查看 OceanBase 提供的官方文档或社区资源,以了解是否有其他方式或工具可用于实现 OceanBase Oracle 模式的 CDC。

    请注意,Flink CDC 和 OceanBase 的集成是一个较新的场景,因此可能仍在不断发展和改进中。建议及时关注 Flink CDC 和 OceanBase 的最新版本和相关更新,以获取最新的功能和支持。

    2023-07-31 23:20:22
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    Flink CDC release-2.4.0 官方并未支持对 OceanBase Oracle 模式进行 CDC,但是您可以通过自行扩展 Flink CDC 来支持该功能。具体来说,您需要实现自己的 Debezium Connector,以便将 OceanBase Oracle 模式中的数据捕获并输出到其他数据源。
    Debezium Connector 是 Flink CDC 的核心组件之一,用于捕获关系型数据库中的数据变化。如果您想要支持 OceanBase Oracle 模式的 CDC,可以通过实现自己的 Debezium Connector 来实现该功能。具体来说,您需要完成以下步骤:
    实现 Debezium Connector 接口:您需要实现 Debezium Connector 接口,并根据 OceanBase Oracle 模式的数据结构,编写相应的数据解析逻辑。
    配置 Flink CDC:在 Flink CDC 中,需要配置相应的连接信息和参数,以便与 OceanBase Oracle 模式建立连接,并使用自己实现的 Debezium Connector 进行 CDC 监控。
    测试和优化:完成上述步骤后,需要对自己实现的 Debezium Connector 进行测试,并根据实际情况进行优化和改进。

    2023-07-29 16:49:59
    赞同 展开评论 打赏
  • 意中人就是我呀!

    支持的,不过要用企业版的logproxy。此回答整理至钉群“Flink CDC 社区”。

    2023-07-26 12:02:55
    赞同 展开评论 打赏

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

相关产品

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

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