问答 2023-08-23 来自:开发者社区

老哥,Flink CDC中我这边从mysql监控两个表往es塞 ,反序列化怎么搞啊?还有我怎么区分是

问题1:老哥,Flink CDC中我这边从mysql监控两个表往es塞 ,反序列化怎么搞啊?还有我怎么区分是哪个表过来的,而且两个表有相同字段问题2:主要我这边去往es塞的时候这个泛型怎么给

问答 2023-08-23 来自:开发者社区

Flink CDC mysql5.7,请问官方说驱动要用8.0.28,报错获取不到这个变量:?

Flink CDC mysql5.7,请问官方说驱动要用8.0.28,报错获取不到这个变量:com.mysql.cj.CharsetMapping.COLLATION_INDEX_TO_COLLATION_NAME 从8.0.26这个变量就变成私有了,请问是我Flink 吃点菜版本用错了吗,我用的是2.0.0?

高性能

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

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

各位老师,咨询下,flink cdc 消费mysql,不消费数据,日志不断的打印这个,请问是什么?

各位老师,咨询下,flink cdc 消费mysql,不消费数据,日志不断的打印这个,请问是什么原因呢、谢谢

问答 2023-08-22 来自:开发者社区

大佬们 Flink CDC读取mysql的数据遇到0000-00-00 00:00:00这是时?

大佬们 Flink CDC读取mysql的数据遇到0000-00-00 00:00:00这是时间数据怎么处理的呀?

问答 2023-08-22 来自:开发者社区

Flink CDC自动任务什么意思? 大佬请教一个有关flink cdc实时同步MySQL的问题,当

Flink CDC自动任务什么意思?大佬请教一个有关flink cdc实时同步MySQL的问题,当我全量同步过来,切接上了增量数据,当运行的过程中报异常提示找不到了binlog的位置该如何解决这个问题?通过检查点重启任务也是报这个binlog 位置已被清除如何解决?

问答 2023-08-22 来自:开发者社区

Flink CDC我这mysql cdc 动态加表后 全量完事之后 不增量了。有遇到过的吗?

Flink CDC我这mysql cdc 动态加表后 全量完事之后 不增量了。有遇到过的吗?

问答 2023-08-22 来自:开发者社区

大佬们,我用了Flink CDC非增量的ckp,然后保留了10个chp,按理说mysql的变化都能?

大佬们,我用了Flink CDC非增量的ckp,然后保留了10个chp,按理说mysql的变化都能捕获到,但是今天有的change没有捕获到,有人知道啥情况吗?

问答 2023-08-22 来自:开发者社区

请教下Flink CDC mysql cdc读取mysql的数据 中文乱码了是为什么呢?本地是正常

请教下Flink CDC mysql cdc读取mysql的数据 中文乱码了是为什么呢?本地是正常的,服务器上乱码了

问答 2023-08-22 来自:开发者社区

请问下Flink CDC,一个job可以监听多个不同实例的mysql binlog吗?

请问下Flink CDC,一个job可以监听多个不同实例的mysql binlog吗(多个source)?

问答 2023-08-22 来自:开发者社区

Flink CDC 您好 jdbccatalog 配置目前看只有mysql和pg支持 ?

Flink CDC 您好 jdbccatalog 配置目前看只有mysql和pg支持 oracle和sqlserver暂未支持 jdbc当前支持oracle和sqlserver?

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

产品推荐

实时计算 Flink

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

+关注