问答 2023-06-04 来自:开发者社区

你好,请教下Flink CDC中 咱们全量读取mysql数据 快照失败异常解决了吗?

你好,请教下Flink CDC中 咱们全量读取mysql数据 快照失败异常解决了吗?

问答 2023-05-30 来自:开发者社区

大佬们 flink cdc 读取MySQL数据写入Kafka,里面的金额字段,这个该如何解决?

问题1:大佬们 flink cdc 读取MySQL数据写入Kafka,里面的金额字段(MySQL decemial()类型)数据和MySQL的不一致,这个该如何解决? 我也纳闷怎么到了Kafka 就变成了字符串 问题2:utf8

问答 2023-05-30 来自:开发者社区

大佬,问下Flink CDC中现在增量读取mysql数据,如果有新增的表想要全量读取,有哪几种方式?

问题1:大佬,问下Flink CDC中现在增量读取mysql数据,如果有新增的表想要全量读取,有哪几种方式呀 ? 问题2:这个参数需要改吗,我看官网没写这个参数,我现在是latest(): .startupOptions(StartupOptions.latest())

问答 2023-05-29 来自:开发者社区

请教一下,Flink CDC中debezium MySQL可以不同步初始化数据吗?实现类似Postg

请教一下,Flink CDC中debezium MySQL可以不同步初始化数据吗?实现类似PostgreSQL snapshot.mode=never的效果?

问答 2023-05-29 来自:开发者社区

大佬 flink cdc 读取MySQL数据写入Kafka,里面的金额字段数据和MySQL的不一致?

大佬 flink cdc 读取MySQL数据写入Kafka,里面的金额字段(MySQL decemial()类型)数据和MySQL的不一致,这个该如何解决? debezium的参数配置

问答 2023-05-14 来自:开发者社区

各位大佬 Flink CDC中有谁知道用mysql-cdc连接器实现同步 数据到下游数据库 ,但是?

各位大佬 Flink CDC中有谁知道用mysql-cdc连接器实现同步 数据到下游数据库 ,但是不能用table api的方式和JdbcSink写sql的方式?

问答 2023-05-09 来自:开发者社区

请问 flink cdc 的mysql连接器有没有监控输入了多少数据,速度是多少的接口

请问 flink cdc 的mysql连接器有没有监控输入了多少数据,速度是多少的接口

问答 2023-05-01 来自:开发者社区

Flink CDC中mysql cdc 可以获取 数据插入的时间吗?

Flink CDC中mysql cdc 可以获取 数据插入的时间吗?

问答 2023-05-01 来自:开发者社区

Flink CDC中你那个时区问题怎么解决的呀,我这边mysql中 timestamp 类型的数据,

Flink CDC中你那个时区问题怎么解决的呀,我这边mysql中 timestamp 类型的数据,用mysql 客户端查询没有问题,但是用 cdc 导出来 就差8小时,怎么办?

问答 2023-05-01 来自:开发者社区

咨询下Flink CDC 中mysql binlog 太大导致oom的问题,几分钟更新了600w数据

咨询下Flink CDC 中mysql binlog 太大导致oom的问题,几分钟更新了600w数据,binlog能切分段过来吗?

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

产品推荐

阿里云实时计算Flink

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

+关注