咨询一个问题:flink CDC 支持 KingBase(人大金仓)的CDC吗?

咨询一个问题:flink CDC 支持 KingBase(人大金仓)的CDC吗?

展开
收起
真的很搞笑 2024-04-29 14:38:20 410 分享 版权
2 条回答
写回答
取消 提交回答
  • TIS是一款基于Web-UI的开源大数据集成工具,通过与人大金仓Kingbase的深度整合,提供高效、灵活的实时开源数据集成方案。它支持增量数据监听和实时写入,兼容MySQL、PostgreSQL和Oracle模式,无需编写复杂脚本,操作简单直观,特别适合非专业开发人员使用。

    TIS对Flink-CDC、Debezium中与Postgresql相关模块进行扩展,扩展了以下两个工程:

    1. flink-connector-kingbase-cdchttps://github.com/qlangtech/flink-cdc/tree/tis-3.1.0/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-kingbase-cdc
    2. debezium-connector-kingbasehttps://github.com/qlangtech/debezium/tree/tis.v1.9.8.Final/debezium-connector-kingbase

    改造涉及的点如下:

    1. 修改PostgresConnection:将Jdbc Connection实例创建由TIS DataSourceFactory来代理完成。
    2. 修改ReplicationMessageColumnValueResolver类:添加对MySQL dbMode下对部分mysql colType,如:tinyint,bigInt等类型的兼容
    3. 扩展KingBase主从复制,GRPC报文传输协议:pg_logicaldec.proto,KingBase扩展了 postgreSQL的主从复制协议,添加了几个字段,所以需要作相应修改

    详细请查看,https://developer.aliyun.com/article/1656488

    2025-03-11 11:26:46
    赞同 展开评论
  • 应该是不支持的
    512a89855c33c372dbd62f79279af807.png
    这是官方的 ,此回答整理自钉群“【②群】Apache Flink China社区”

    2024-04-29 15:22:06
    赞同 1 展开评论

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

还有其他疑问?
咨询AI助理