---
title: "数据订阅 - OceanBase 数据库 V4.6.0 | OceanBase 文档中心"
description: 数据订阅 数据订阅通过 变更数据捕获（CDC） 从上游持续 读取数据库日志 （如 MySQL Binlog、OceanBase Binlog 服务等），将增量变更解析、排序或转换后，在 目标端回放 ——常见目标包括 OceanBase 、 Kafka 以及再由 Flink/自定义消费者写入分析库或宽表。 典型场景 ：…
---
切换语言

- 中文站 - 简体中文
- International - English
- 日本站 - 日本語

文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*P8CuR4UJ_FkAAAAAAAAAAAAADiGDAQ/original) OceanBase 数据库分布式版 - V 4.6.0

# 数据订阅

更新时间：2026-07-03 09:06:30

[编辑](https://github.com/oceanbase/oceanbase-doc/edit/V4.6.0/zh-CN/620.obap/300.obap-data-transfer/400.data-synchronization/300.data-subscription.md)  

数据订阅通过**变更数据捕获（CDC）**从上游持续**读取数据库日志**（如 MySQL Binlog、OceanBase Binlog 服务等），将增量变更解析、排序或转换后，在**目标端回放**——常见目标包括 **OceanBase**、**Kafka** 以及再由 Flink/自定义消费者写入分析库或宽表。

**典型场景**：实时同步到 BI/数仓、缓存与搜索引擎刷新、迁移割接期间的增量追平、经 Kafka 做流量削峰与多团队消费、OceanBase Binlog 出湖等。

## 使用 Canal 订阅 MySQL Binlog

Canal 模拟 MySQL Slave **订阅 Binlog**，将行级变更投递到客户端；可配置为直连同步至 OceanBase，或通过 **TCP / Kafka / RocketMQ / RabbitMQ** 等模式先写入消息系统，再由下游消费并写入目标库（含 OceanBase）。

| 场景 | 说明 | 文档 |
| --- | --- | --- |
| MySQL → OceanBase（Canal） | 基于 MySQL Binlog 解析，增量写入 OceanBase。 | [使用 Canal 从 MySQL 数据库同步数据到 OceanBase 数据库](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005682284) |
| OceanBase → MySQL（Canal） | 源端需 **OceanBase Binlog 服务**，将日志以类 MySQL Binlog 形式供订阅。 | [使用 Canal 从 OceanBase 数据库同步数据到 MySQL 数据库](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005682279) |
| MySQL → OceanBase（CloudCanal） | 社区版管道，同属 Binlog 类同步方案，可与 Canal 对照选型。 | [使用 CloudCanal 从 MySQL 数据库迁移数据到 OceanBase 数据库](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005682286) |

## 使用 Flink CDC 订阅多源数据库

Flink CDC 在 Flink 上提供 **Database CDC Source**，可从多种数据库拉取**存量 + 增量**，并配合 Flink SQL 做关联、打宽、聚合，再写入 Kafka、JDBC（含 OceanBase）、Hive 等 Sink。适合**多源合一**、**实时加工**与**Exactly-Once** 要求较高的管道。

| 场景 | 说明 | 文档 |
| --- | --- | --- |
| MySQL → OceanBase | MySQL CDC Source，增量同步至 OceanBase。 | [使用 Flink CDC 从 MySQL 数据库同步数据到 OceanBase 数据库](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005682282) |
| OceanBase → MySQL | 依赖 **OceanBase Binlog 服务**，在 Flink 中创建 OceanBase CDC 源表。 | [使用 Flink CDC 从 OceanBase 数据库迁移数据到 MySQL 数据库](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005682277) |
| OceanBase 增量（ChunJun / FlinkX） | 基于 Binlog 服务与 `oblogclient` 的增量同步框架。 | [使用 ChunJun 从 OceanBase 数据库迁移数据到 MySQL 数据库](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005682278) |
| StarRocks → OceanBase（Flink 作业） | OceanBase 提供的 Flink 迁移工具，适合与 SR 加工链路基表不一致的场景。 | [使用 Flink-OMT 从 StarRocks 数据库同步数据到 OceanBase 数据库](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005682045) |

## 订阅数据写入 Kafka / OceanBase 场景

常见模式是：**CDC 或 Canal 解析日志 → 写入 Kafka（缓冲、多订阅）→ Flink/OMS/自研消费者 → 落 OceanBase 或其它存储**。也可由 Flink CDC **直接** Sink 到 OceanBase JDBC，省略 Kafka，按吞吐与耦合度取舍。

| 场景 | 说明 | 文档 / 链接 |
| --- | --- | --- |
| TiDB：TiCDC → Kafka → OMS → OceanBase | TiDB 增量经 Kafka 投递，由 OMS 消费写入 OceanBase MySQL 租户（新建数据源需绑定 Kafka）。 | [使用 OMS 迁移 TiDB 数据库到 OceanBase 数据库（MySQL 兼容模式租户）](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005682281) |
| OMS 对接 Kafka / RocketMQ / Datahub | 产品侧支持的下游消息与数据集成形态，可与订阅链路组合。 | [数据迁移概述 · OMS 支持的数据源](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005681910)（迁移方案支持情况表）；[OMS 使用文档](https://www.oceanbase.com/docs/oms-doc-cn) |
| Canal → Kafka（再消费写 OB） | Canal `serverMode` 等配置为 `kafka` 等时，变更先入 Topic，再由消费者写入 OceanBase。 | [使用 Canal 从 MySQL 数据库同步数据到 OceanBase 数据库](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000005682284) |
| Flink CDC → Kafka → 下游 | Flink 将 CDC 流写入 Kafka，供实时数仓、多团队消费；Sink 选型见 Flink 文档。 | [Flink Kafka Connector](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/kafka/) |
| Flink / JDBC 直写 OceanBase | 不经 Kafka，由 Flink JDBC 或 OceanBase 相关 Connector 直接写入内表（与导入、旁路能力配合时注意语义）。 | [Flink JDBC SQL Connector](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/)；导入侧参见 [数据导入概述](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000006277724) |

 上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线