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

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

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

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

mysqlcdc使用的时候,如果表名是中文,增量记录不能同步到kafka,全量是可以。为什么?

mysqlcdc使用的时候,如果表名是中文,增量记录不能同步到kafka,全量是可以。有人碰到过这个问题吗?

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

flink cdc同步,kafka必须设置成1个partition才能确保数据一致性吗?

flink cdc同步binglog到kafka,flink再消费kafka到目标库,kafka必须设置成1个partition才能确保数据一致性吗?

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

我用cdc同步大表到kafka 用了2.3的切块 在数据fetch的时候报jvm堆内存溢出

我用cdc同步大表到kafka 用了2.3的切块 在数据fetch的时候报jvm堆内存溢出 里面是记录什么了吗? 真实数据其实会写到db history topic里吧?

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

Flink MySQL整库同步Kafka示例

Flink MySQL整库同步Kafka示例

问答 2022-11-02 来自:开发者社区

cdc同步mysql到Kafka时 若mysql历史数据(大概十几亿条)较多 startup设置

cdc同步mysql到Kafka时 若mysql历史数据(大概十几亿条)较多 startup设置为initial时,任务总是被kill掉; startup采用latest时一切正常,问下大佬们,像这种前期有大量历史数据的,首次要全量,一般都采用什么方案呀?

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

采集 binlog的变化同步到 kafka,这里 binlog每次的偏移量,存储在哪里

Debezium 采集 binlog的变化同步到 kafka,这里 binlog每次的偏移量,存储在哪里,有大神帮忙解答一下吗

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

mongoshake同步bigdecimal字段到Kafka,value丢失,是什么原因呢?

mongoshake同步bigdecimal字段到Kafka,value丢失,是什么原因呢?

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

有没有用oracle cdc同步2个数据库的 我用cdc->kafka ->消费kafka拼接s

有没有用oracle cdc同步2个数据库的 我用cdc->kafka ->消费kafka拼接sql能行吗?

问答 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了,怎么办?

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注