开发者社区 > 大数据与机器学习 > 正文

大佬有知道 Flink CDC怎么接入tdsql-postgresql 么 也就是tbase?

大佬有知道 Flink CDC怎么接入tdsql-postgresql 么 也就是tbase?image.png

展开
收起
真的很搞笑 2023-06-04 18:49:27 115 0
1 条回答
写回答
取消 提交回答
    • Flink CDC可以接入tdsql-postgresql,实现从tdsql-postgresql中实时读取数据变化,并将其转换为Flink表或流。具体的步骤如下:
      • 在tdsql-postgresql中开启逻辑复制功能,以便生成wal2json格式的二进制日志。
      • 在Flink中创建一个PostgreSQL CDC连接器,指定tdsql-postgresql的连接信息、数据库名、表名、用户名、密码等参数。
      • 在Flink中使用SQLTable API对PostgreSQL CDC连接器进行操作,比如查询、过滤、转换、输出等。
    2023-10-13 10:59:26
    赞同 1 展开评论 打赏

大数据领域前沿技术分享与交流,这里不止有技术干货、学习心得、企业实践、社区活动,还有未来。

相关产品

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

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

    相关镜像