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

flink cdc有支持opengauss的connector吗?

flink cdc有支持opengauss的connector吗?

展开
收起
真的很搞笑 2024-01-01 09:00:59 257 0
5 条回答
写回答
取消 提交回答
  • Apache Flink CDC官方发行版本并不直接支持OpenGauss数据库的CDC功能。不过,社区中有开发者提到可以通过自定义编译Debezium并集成OpenGauss connector来实现Flink与OpenGauss之间的CDC连接。

    若要在Flink CDC中使用OpenGauss作为数据源,可能需要参照华为开源的基于Debezium的OpenGauss CDC解决方案进行适配和整合。这意味着你需要自行构建一个包含OpenGauss CDC连接器的定制版Flink CDC。

    2024-01-02 09:51:43
    赞同 1 展开评论 打赏
  • image.png
    这个表里没有的应该就不支持 ,此回答整理自钉群“Flink CDC 社区”

    2024-01-02 03:48:46
    赞同 展开评论 打赏
  • flink cdc官方暂时没有opengauss的connector。
    image.png
    在未来计划里应该有支持。
    image.png

    当下使用的话需要改造源码,增加GaussDB相关的代码。比如增加:org.apache.flink.connector.jdbc.databases.opengauss包,并重写相关代码。

    ——参考来源于[Flink CDC官网]

    2024-01-01 21:40:42
    赞同 1 展开评论 打赏
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink CDC支持opengauss的connector,可以通过自己手写Sink将CDCFlink CDC支持opengauss的connector,可以通过自己手写Sink将CDC的数据直接汇入我们的目标数据库,也可以通过Flink SQL的方式将数据汇入到opengauss。

    2024-01-01 13:03:46
    赞同 展开评论 打赏
  • 目前,Flink CDC 的官方版本并未提供对opengauss的支持。然而,Flink作为一个开源项目,它提供了可扩展的架构和接口,您可以通过自定义开发来支持其他数据库。具体来说,可以自己编写一个Sink将CDC的数据直接汇入到目标数据库,或者通过Flink SQL的方式将数据汇入到opengauss。另一种可行的方式是,打包一个包含openGauss connector的debezium,然后再打包一个flinkCDC,把debezium openGauss connector包进去。总的来说,虽然直接的支持可能不存在,但是通过一些开发工作,还是可以实现opengauss的Flink CDC的。

    2024-01-01 10:58:56
    赞同 展开评论 打赏

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

相关产品

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

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