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

flinkcdc采集mysql数据,写入kafka,可以单独往某个topic里面写ddl吗?

问题1:flinkcdc采集mysql数据,写入kafka,可以单独往某个topic里面写ddl吗?问题2:flinkcdc怎么单独采集ddl呢?有参考连接吗?

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

社区大佬们早上好我有个问题我在做数据集成基于flinkcdc实现的时候我在mysql到kafka生?

社区大佬们早上好我有个问题我在做数据集成基于flinkcdc实现的时候我在mysql到kafka生成了一个stream graph,kafka到olap生成了一个stream graph,flink可以将这两个stream graph合并起来实现mysql2kafka2olap嘛?

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

各位大佬,idea中测试使用FlinkCDC SQL 读取Mysql 数据写入Kafka中,代码中创

各位大佬,idea中测试使用FlinkCDC SQL 读取Mysql 数据写入Kafka中,代码中创建了checkpoint,发现每次重启Idea中FlinkCDC的代码都会全量读取Mysql数据并写入Kafka,请教一下如何以增量的方式读取Mysql数据写入Kafka呢?是不是每次重启程序都会全量读取Mysql数据?

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

大佬们,flinkcdc以sql方式读取mysql入kafka,格式只能下面那样吗,输出的时候能不能

大佬们,flinkcdc以sql方式读取mysql入kafka,格式只能下面那样吗,输出的时候能不能有source字段

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

产品推荐

消息队列

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

+关注