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

对于Flink CDC提示不能提交offset,但是能把数据成功写到数据库,怎么让他写入失败?

对于Flink CDC,Kafka用xshell在服务器开一个消费kafka到mysql :同样的topic和gourpId用flink启动一个来消费,flink提示不能提交offset,但是能把数据成功写到数据库,怎么让他写入失败?

阿里云文档 2024-07-01

CDC相关的常见问题汇总

本文介绍CDC相关的常见问题。

基于阿里云Hologres&Flink实时计算平台搭建数据仓库(实时)

23 课时 |
321 人已学 |
免费

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

1 课时 |
951 人已学 |
免费

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

1 课时 |
517 人已学 |
免费
开发者课程背景图
阿里云文档 2024-06-28

社区CDC

本文为您介绍如何在阿里云实时计算Flink版中使用社区版CDC(Change Data Capture)连接器,以及更改连接器名称。

问答 2024-06-16 来自:开发者社区

在Flink CDC中在做完数据的迁移后,特别是涉及到跨区域迁移,目前有比较好的数据库对比工具吗?

在Flink CDC中在做完数据的迁移后,特别是涉及到跨区域迁移,目前有比较好的数据库对比工具吗?

问答 2024-06-05 来自:开发者社区

在Flink CDC中同步mysql数据时候相比MIXED 是不是产生更多日志,会对数据库有影响吗?

在Flink CDC中同步mysql数据时候 binlog_format=ROW,这个相比MIXED 是不是产生更多日志,会对数据库有影响吗?

问答 2024-05-07 来自:开发者社区

Flink CDC里一般轨迹点数据用什么数据库存比较好?

Flink CDC里一般轨迹点数据用什么数据库存比较好?

问答 2024-05-07 来自:开发者社区

Flink CDC里使用同步mysql数据时 无法指定需要的时区,只能按数据库本身的时区进行设置?

Flink CDC里使用同步mysql数据时 无法指定需要的时区,只能按数据库本身的时区进行设置? 多个实例时区不一致集成到一起的时候咋办 ?是这样 问题在于每个任务获取的时间戳附带时区不一样 很影响下游对数据的统一处理 还得针对不同源的特定时间字段做对应时区转换。我现在在source端无法处理时区问题。 我没法识别同步的表哪些字段是时间戳 应该做时区处理。表太多了。Caused...

阿里云文档 2024-04-11

Postgres CDC连接器

Postgres CDC可用于依次读取PostgreSQL数据库全量快照数据和变更数据,保证不多读一条也不少读一条数据。即使发生故障,也能采用Exactly Once方式处理。本文为您介绍如何使用Postgres CDC连接器。

问答 2024-03-25 来自:开发者社区

Flink CDC里当 oracle 数据不开启整个数据库的补充日志,只开启单个表的,这个再启动吗?

Flink CDC里当 oracle 数据不开启整个数据库的补充日志,只开启单个表的,这个再启动 flink cdc 的时候需要设置哪个参数配置?flink oracle cdc 在访问 oracle 的时候,不开启整个库的补充日志,只开启了单个表的补充日志,现在在启动 cdc 的时候报错了: 报错信息为:Supplemental logging not properly configured.....

问答 2024-03-09 来自:开发者社区

flink cdc 3.0 整库同步数据,会导致业务数据库正常访问吗?比如被锁定,或者负载变高。

我现在使用的是flink cdc pipeline的方式,整库从mysql同步到StarRocks里面,首次全量是否会对mysql造成大量资源消耗,导致影响业务服务。

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

实时计算 Flink版cdc相关内容

实时计算 Flink版更多cdc相关

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注