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

Flink CDC读取mysql到kafka,更新的话op不应该是u吗,出来是d和c?

Flink CDC读取mysql到kafka,更新的话op不应该是u吗,出来是d和c?

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

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

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

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

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

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

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

flink 1.15.3 mysql cdc 2.3.0 同步到kafka 出现了这个异常信息Fa

flink 1.15.3 mysql cdc 2.3.0 同步到kafka 出现了这个异常信息Failed to deserialize data of EventHeaderV4{timestamp=1681910072000, eventType=WRITE_ROWS, serverId=2578535688, headerLength=19, dataLength=8182, nextP.....

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

flink cdc 读取mysql binlog的顺序是严格的吗?我这读过来写到kafka 的时候顺

flink cdc 读取mysql binlog的顺序是严格的吗?我这读过来写到kafka 的时候顺序有点变化

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

关于Flink CDC,MySQL整库同步Kafka,数据会不会过期呀?

关于Flink CDC,MySQL整库同步Kafka,数据会不会过期呀?

问答 2022-12-19 来自:开发者社区

Flink MySQL整库同步Kafka示例

Flink MySQL整库同步Kafka示例

问答 2022-08-24 来自:开发者社区

求助:flink cdc 从oracle或者mysql 同步到kafka,但是最近一个update操

求助:flink cdc 从oracle或者mysql 同步到kafka,但是最近一个update操作,变成了两条记录,一条delete,然后一条insert,之前是一条数据,before有之前数据,after是修改后的数据,然后记录中操作类型是op:u,现在就变成op:d+op:c了,怎么办?

问答 2022-07-22 来自:开发者社区

大佬们,flink sql client实现 mysql表实时同步到hive,除了中间转kafka再

大佬们,flink sql client实现 mysql表实时同步到hive,除了中间转kafka再写hive,有没有别的方式,能一步到位。

问答 2022-07-08 来自:开发者社区

请问一下各位大佬,使用flink cdc 2.1.1版本进行mysql到kafka的数据同步,正常同

请问一下各位大佬,使用flink cdc 2.1.1版本进行mysql到kafka的数据同步,正常同步了一个月时间,昨天数据库下线,flink cdc job没有抛出异常,看日志一直在不断重连数据库,重连了十几个小时,我们希望上游源数据库出现问题,flink cdc能够立即感觉,有什么办法吗?

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

产品推荐

数据库

数据库领域前沿技术分享与交流

+关注
相关镜像