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

Flink CDC 里 这个pr 支持首次全量写入kafka?

Flink CDC 里 这个pr 支持首次全量写入kafka? 直接jdbc 从数据库拉取数据,也是输出 debeium-json and canal-json ?

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

Flink CDC使用datax或者其他全量工具同步到kafka; 是这个意思吧?

Flink CDC使用datax或者其他全量工具同步到kafka;第二步等kafka消费端完成了消费;第三步消费完后启动flink cdc增量方式,把同步全量开始的时间转换时间戳作为flink增量的时间戳开始同步更新;全量(datax)和增量(flink cdc)结合,是这个意思吧?

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

Flink CDC全量是要读取完,kafka事务时间要大于全量读取完时间?

Flink CDC全量是要读取完,kafka事务时间要大于全量读取完时间?

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

各位老板 cdc全量+增量读取维表 然后主流是kafka数据 如果程序启动之前kafka存在堆

各位老板 cdc全量+增量读取维表 然后主流是kafka数据 如果程序启动之前kafka存在堆积数据的话 就会出现cdc维表全量还没读取完 就开始消费kafka数据了 那这样会存在一部分数据关联不上 有遇到的嘛?

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

各位老板 如何保证cdc全量读取完之后 再读取kafka的数据呀? 因为cdc读的是配置数据

各位老板 如何保证cdc全量读取完之后 再读取kafka的数据呀? 因为cdc读的是配置数据 如果全量阶段没有读取完 害怕有部分数据会关联不上啊?

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

产品推荐

消息队列

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

+关注