问答 2023-07-13 来自:开发者社区

问大家个Flink CDC问题,我怎么样读取mysql的binlog,我发现cdc前面都是全量查询?

问大家个Flink CDC问题,我怎么样读取mysql的binlog,我发现cdc前面都是全量查询阶段,我不想要查询数据,只想要读取某个表的完整的binlog?

问答 2023-07-13 来自:开发者社区

Flink CDC中用jdbc-connector写入mysql,为啥速度那么慢?用jdbc cat

Flink CDC中用jdbc-connector写入mysql,为啥速度那么慢?用jdbc catalog写入的,都是默认配置,有啥优化办法吗?

高性能

基于 Flink CDC 打造企业级实时数据同步方案

传统的数据集成通常由全量和增量同步两套系统构成,在全量同步完成后,还需要进一步将增量表和全量表进行合并操作,这种架构的组件构成较为复杂,系统维护困难。本方案提供 Flink CDC 技术实现了统一的增量和全量数据的实时集成。
技术解决方案背景图
问答 2023-07-13 来自:开发者社区

大佬们,Flink CDC中mysql的blob我想直接转成字符串写到kafka,用sql的方式怎?

大佬们,Flink CDC中mysql的blob我想直接转成字符串写到kafka,用sql的方式怎么写?

问答 2023-07-13 来自:开发者社区

Flink CDC中可不可以配置mysql源端控制提取变更数据的间隔 类似配置成每5秒获取变更数据?

Flink CDC中可不可以配置mysql源端控制提取变更数据的间隔 类似配置成每5秒获取变更数据这种?看源码里好像真没有TIMESTAMP,但是枚举里有定义oracle

问答 2023-07-13 来自:开发者社区

大佬们,请教下,Flink CDC中有遇到 cdc 同步 mysql 快照只同步了部分数据后,就不?

大佬们,请教下,Flink CDC中有遇到 cdc 同步 mysql 快照只同步了部分数据后,就不再同步的情况吗?版本是 2.4.0?

问答 2023-07-13 来自:开发者社区

Flink CDC中cdc mysql sql语法有参数控制只捕获insert语句吗?

Flink CDC中cdc mysql sql语法有参数控制只捕获insert语句吗?

问答 2023-07-13 来自:开发者社区

Flink CDC中StartupOptions.initial() 全量监听Mysql写入Red?

Flink CDC中StartupOptions.initial() 全量监听Mysql写入Redis的时候是乱序的?怎么保证写入是顺序,我数据库是顺序,全量写入Redis是乱序,历史数据要保证顺序呢,我开启的并行度是1

问答 2023-07-02 来自:开发者社区

flink cdc 2.3.0 sql 同步oracle表到mysql表,其中oracle有个?

flink cdc 2.3.0 sql 同步oracle表到mysql表,其中oracle有个CLOB类型字段 同步到mysql的text类型过来都是null, oracle源表中是有值的,有人遇到过么?

问答 2023-07-02 来自:开发者社区

Flink CDC中我使用datastream的方式消费mysql的binlog,正常消费没有问题?

问题1:Flink CDC中我使用datastream的方式消费mysql的binlog,正常消费没有问题,但是指定时间戳消费就是消费不到数据。目前的mysql-cdc的版本是2.4.0,flink的版本是1.15.3,也没看到有什么报错信息,求指点?你们有使用datastream,flink的mysql-cdc的从指定时间戳消费数据的吗?有成功的案例吗? 问题2:我目前测试从最开始的消费也就5....

问答 2023-07-02 来自:开发者社区

请问下 flink cdc 全量初始化mysql表时,主键是字符串类型同步很慢,这个需要咋优化配置?

请问下 flink cdc 全量初始化mysql表时,主键是字符串类型同步很慢,这个需要咋优化配置参数?目前我设置了 chunk size 4k-10w之间变化不明显,速度很慢1-2K/s,如果主键时bigiint 没啥问题?

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

产品推荐

实时计算 Flink

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

+关注