cdc抽取mysql整个实例的binlog，有没有方案通过配置的方式将这些库表拆开分发到kafka

收起

游客3oewgrzrf6o5c 2022-08-03 13:43:40 694 版权

1 条回答

写回答

取消提交回答

游客bcfx2q4kttgbm

直接写一下路由不就好了？（此答案整理自Flink CDC 社区）

2022-08-03 14:57:15 举报

赞同评论

评论
全部评论 (0)
登录后可评论

问答分类：

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

问答标签：

mysql binlog 云数据库 RDS MySQL 版binlog cdc云数据库 RDS MySQL 版 cdc mysql云消息队列 Kafka 版云数据库 RDS MySQL 版kafka

问答地址：

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

相关问答

实时计算 Flink版

flink cdc mysql到kafka为啥会丢数据呢？

flink cdc datastream方式同步mysql数据到kafka，多分区怎么保证有序性？

flink cdc 读mysql 写进kafka，在执行一段时间后，任务就一直出于初始化状态？

使用flinkcdc 3.1.1 同步mysql到kafka，改表结构之后就不能从特定位置起了吗？

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到这个字段？

在Flink CDC中，用pipeline 连接器同步mysql数据到kafka报错了，缺少什么？

102

在Flink CDC中这种模式Kafka到mysql可以kakfa到doris不行，也不报错为什么？

在Flink CDC中MySQL 整库同步 Kafka，不支持动态加表功能吗？

在Flink CDC中MySQL整库同步，Kafka Pipeline 不支持指定分区吗？

在Flink CDC中CDC3.2 可以pipeline 方式mysql cdc 到 kafka？

大数据与机器学习

实时计算 Flink

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

我要提问

收录在圈子:

阿里云实时计算Flink

199210

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

Dataphin功能Tips系列（38）-API的非必填参数(1)

Dataphin功能Tips系列（39）-API的非必填参数(2)-未传参时指定默认值

Dataphin功能Tips系列（50）-离线集成输入端支持mysql数据源分库分表

Dataphin功能Tips系列（35）-通过Python脚本连接数据库

Dataphin功能Tips系列（49)-审计日志导出