Flink CDC使用postgresql cdc获取数据,有遇到这个问题的吗?

Flink CDC使用postgresql cdc获取数据,日志一直打印这个Exported 432162 records for split 'zjcrm_std.mer_trade_hd:4' after 00:03:44.535 ,最后直至task GC,有遇到这个问题的吗?

iceberg数据库的Flink cdc,是不是也是用postgreSQL数据库的cdc?

iceberg数据库的Flink cdc,是不是也是用postgreSQL数据库的cdc?

「大师课」PolarDB 高手课

20 课时 |
9603 人已学 |
免费

高校精品课-华东师范大学-云原生数据库

13 课时 |
277 人已学 |
免费

AnalyticDB PostgreSQL 企业智能数据中台:一站式管理数据服务资产

10 课时 |
292 人已学 |
免费
开发者课程背景图

flink postgresql cdc实时同步(含pg安装配置等)

1. 环境信息类型版本/描述docker20.10.9Postgresql10.6初始化账号密码:postgres/postgres普通用户:test1/test123数据库:test_dbflink1.13.62. 安装step1: 拉取 PostgreSQL 10.6 版本的镜像:docker ...

我看到最新的flink cdc, postgresql 依然不支持 这个模式,请问是底层不太好实现?

我看到最新的flink cdc, postgresql 依然不支持 StartupOptions.specificOffset 这个模式,请问是底层不太好实现嘛,还是有其他有问题?有没有位大佬自己实现该功能的

Flink CDC哪位能发下新版本postgresql flinkcdc连接器?

Flink CDC哪位大神能发下新版本postgresql flinkcdc连接器?

请问flink使用jdbc catalog读取postgresql中的数据,该怎么处理呢?

请问flink使用jdbc catalog读取postgresql中的数据,schema名里包含中横线,该怎么处理呢?select * from enjoy-pms.rl_leave_problem limit 10; 报错org.postgresql.util.PSQLException: ERR...

Flink CDC同步开源的那个postgresql数据库有碰到这个情况的不?

Flink CDC阿里云基于postgresql做的polardb我用flink 2.2 postgresql 连接器做同步。查询polardb的slot显示没有消费,但是我kafka显示收到了数据。这导致wal日志持续增加且不删除。同步开源的那个postgresql数据库有碰到这个情况的不?

Flink cdc 怎么通过SSH代理简介postgresql呢?

Flink cdc 怎么通过SSH代理简介postgresql呢?

Flink CDC通过jdbc链接postgresql,url后面需要带schema 需要怎么写?

Flink CDC通过jdbc链接postgresql,url后面需要带schema 需要怎么写?

问个问题,flink cdc2.4.1 postgresql 不支持 这个模式吗?

问个问题,flink cdc2.4.1 postgresql 不支持 StartupOptions.timestamp() 这个模式吗?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

云原生数据库 PolarDBflink相关内容