flink cdc sql将一个source,sink到pg和kafka,这种场景支持吗?

flink cdc sql将一个source,sink到pg和kafka,这种场景支持吗?

Flink CDC里从pg库采集cdc数据,flink程序断了之后,为啥不能指定从断的地方重新消费?

Flink CDC里从pg库采集cdc数据,flink程序。断了之后,为啥不能指定从断的地方重新消费changelog数据呢,现在代码里只支持initial和latest,其它模式不支持怎么办?所以说不能够像我说的那样,继续从断掉的点位读吗?能捕获程序停止之后的物理删除数据吗?我有一个场景,就是要双...

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图
Flink CDC产品常见问题之pg cdc程序已经停了但是执行删不掉如何解决

Flink CDC产品常见问题之pg cdc程序已经停了但是执行删不掉如何解决

问题一:Flink CDC里pg cdc程序已经停了,但是执行删不掉什么回事? Flink CDC里pg cdc程序已经停了,但是执行 pg_drop_replication_slot('flink')删不掉是怎么回事?CREATE_REPLICATION_SLOT "flink" LOGICAL ...

Flink CDC 里2.4cdc同步pg比原来时间多8小时,修改什么参数?

Flink CDC 里2.4cdc同步pg比原来时间多8小时,修改什么参数?没看见pg有修改时区的参数啊?

在使用flink cdc pg时 有遇到这个问题吗?

在使用flink cdc pg时 有遇到这个问题吗?] -> TableToDataSteam (1/1)#0. Failure reason: Checkpoint was declined. at org.apache.flink.streaming.api.operators.Strea...

目前Flink CDC读取pg数据库的表,怎么设置参数提高同步效率,有文档吗?

目前Flink CDC读取pg数据库的表,如果表里面的数据量特别大,怎么设置参数提高同步效率,有文档吗?

Flink CDC有没有遇到将pg number 类型解析出来是这个值的?

Flink CDC有没有遇到将pg number 类型解析出来是这个值的?

Flink CDC修改pg 这2个参数,但是第二个参数不生效,有大佬碰到过么?

Flink CDC修改pg 这2个参数,但是第二个参数不生效,有大佬碰到过么?max_wal_senders = 999max_replication_slots = 996

flink cdc读取pg时报这个错有遇到过吗?

flink cdc读取pg时报这个错有遇到过吗?

Flink CDC里cdc 同步 PG的数据,会对线上业务库性能影响很大么?

Flink CDC里cdc 同步 PG的数据,为了获取 delete/update 操作,需要 [ALTER TABLE reptest REPLICA IDENTITY FULL;] ,会对线上业务库性能影响很大么? 业务库需要所有表都同步的话?

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink CDC 打造 企业级实时数据集成方案
任庆盛|Flink CDC + Kafka 加速业务实时化
Flink CDC Meetup PPT - 龚中强
立即下载 立即下载 立即下载

实时计算 Flink版cdc相关内容

实时计算 Flink版更多cdc相关