备案控制台

开发者社区

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

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

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

展开

收起

cuicuicuic 2023-08-01 14:32:59 62 0

1 条回答

写回答

取消提交回答

xin在这

回答1:只能java代码处理
回答2:你把数据过滤掉，不就剩下ddl了，此回答整理自钉群“Flink CDC 社区”

2023-08-01 14:40:19

赞同展开评论打赏

问答分类：

SQL 消息中间件关系型数据库 MySQL Kafka 云消息队列 Kafka 版云数据库 RDS MySQL 版实时计算 Flink版

问答标签：

云数据库 RDS MySQL 版数据云数据库 RDS MySQL 版ddl 数据云消息队列 Kafka 版云消息队列 Kafka 版数据云数据库 RDS MySQL 版flinkcdc

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

相关问答

实时计算 Flink版

有没有测试过flink拉取kafka的单topic速度极限是多少？

54

2

0

mysql增加默认值，这个ddl操作，会导致flink cdc任务同步失败吗？

35

4

0

flink cdc 2.4.1 支持mysql到doris实时抓取ddl并apply到doris嘛？

39

1

0

想解析MySQL ddl语句，Flink CDC有没有什么工具方法呢？

33

2

0

Flink因为源表的字段发生更改，请问对应的kafka topic，是否需要删掉重建呢？

17

1

0

flink cdc采集binlog到kafka极限是多少呀？多并行度，能提升采集性能吗？

43

2

0

数据传输DTS在mysql之间同步时，可以屏蔽索引的DDL吗？

27

1

0

Flink CDC中flinksql采集mysql，这怎么解析到kafka，有方法解决吗？

24

0

0

Flink CDC2.×版本除了支持捕获MySQL ddl消息外，还支持其他数据源的ddl吗？

24

1

0

我们想通过eventbrage实现rds ddl和部分dml的监听，都会默认接入吗？

35

1

0

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

热门讨论

热门文章

FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？

flink1.15启动后无法访问webui的问题有人遇到过吗

Flink1.17为什么需要JDK 11呢？JDK8我试了也能运行

Caused by: org.apache.kafka.common.errors.TimeoutE

Flink CDC有遇见这个问题的吗？

flinkcdc连接oracle-19c提示不支持logmnr大家有遇到的吗，报ORA-44609？

flink 1.18必须配套JDK11吗 1.8是不是不行了呢？

Flink CDC中The MySQL server has a 兄弟们这个错误咋搞啊？

flink都是100%占用，请问是什么情况呢？

Flink这个 busy 是啥意思？

展开全部

数据仓库介绍与实时数仓案例

广告场景下的实时计算

【对话科技】Flink技术介绍和新功能展望

Apache Flink 漫谈系列(15) - DataStream Connectors之Kafka

Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL

基于 Flink 的实时数仓生产实践

Apache Flink 漫谈系列(13) - Table API 概述

Flink入坑指南第四章：SQL中的经典操作Group By+Agg

实时欺诈检测（风控）

如何在 Flink 1.9 中使用 Hive？

展开全部

相关课程

更多

云数据库MySQL版快速上手教程

19904

13

去学习

分布式消息系统 Kafka 快速入门

640

24

去学习

阿里云云原生数据仓库AnalyticDB MySQL版使用教程

112

5

去学习

MySQL实战进阶

4063

7

去学习

数据库及SQL/MySQL基础

5459

22

去学习

云数据库MySQL快速入门

2548

10

去学习

相关电子书

更多

Java Spring Boot开发实战系列课程【第16讲】：Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载

MaxCompute技术公开课第四季之如何将Kafka数据同步至MaxCompute 立即下载

消息队列kafka介绍 立即下载

相关实验场景

更多