---
title: "新建 OceanBase 至 RocketMQ 的数据同步链路 | OceanBase 文档中心"
description: 新建 OceanBase 至 RocketMQ 的数据同步链路 消息队列 RocketMQ 版是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。OMS 的数据同步功能可以帮助您实现 OceanBase 物理表和 RocketMQ 数据源之间的数据实时同步，扩展消息处理能力。…
---
切换语言

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

文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*L03BS6f-o40AAAAAAAAAAAAADiGDAQ/original) 迁移服务 OMSV 2.1.0 企业版

# 新建 OceanBase 至 RocketMQ 的数据同步链路

更新时间：2023-06-25 10:17:56

消息队列 RocketMQ 版是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。OMS 的数据同步功能可以帮助您实现 OceanBase 物理表和 RocketMQ 数据源之间的数据实时同步，扩展消息处理能力。

## 前提条件

- 已创建 RocketMQ 数据源，详情请参见 [添加 RocketMQ 数据源](https://www.oceanbase.com/docs/enterprise-oms-doc-cn-10000000000374105)。
 - 在您的 RocketMQ 实例中，您需要提前创建名称为 **oms_test_topic** 、属性为 **分区顺序消息** 的 Topic。

## 操作步骤

1. 新建同步链路。

      1. 登录 OMS 控制台。
      2. 在左侧导航栏，单击 **数据同步** 。
      3. 在 **数据同步** 页面，单击右上角的 **新建同步链路** > **新建数据库到大数据同步链路** 。
 2. 选择源和目标。

      1. 在 **选择源和目标** 页面，选择 **同步类型** 为 **OB → RocketMQ** 。
      2. 设置 **同步链路名** **称** 。

        **说明**

        同步链路名称支持中文、数字和英文字母的组合，且不得超过 500 个字符。
      3. 选择 **表类型** 和源端名称。 **表类型** 包括 **单表** 和 **多表** 。
      4. 选择需要同步的 **数据表** 。在左侧选中需要同步的数据表，单击 **>** ，将其添加至右侧列表中。

        ![选择表](https://help-static-aliyun-doc.aliyuncs.com/assets/img/zh-CN/7653918061/p202770.png)
      5. 指定 **分片列** 。仅选择 **表类型** 为 **单表** 时，需要指定 **分片列** 。

        请在文本框中输入物理单表的字段名作为分片列，多个字段名之间请使用英文逗号（,）分隔。

        **说明**

             - 源端是 OceanBase Oracle 模式时，分片列处填写的字段名应全部转为大写字母。
             - 请保证分片列的正确性，分片列填写错误会导致数据同步任务失败。
      6. 设置 **目标端** 。

        | 参数 | 描述 |
        | --- | --- |
        | 数据源 | 请在下拉列表中选择已创建的 RocketMQ 数据源。 您可以单击 **查看数据源** ，进入 **数据源列表** 页面查看所有已创建的数据源。 |
        | Topic | 输入一个已存在的 Topic。如果您未创建 Topic，可以直接输入 Topic 名称，OMS 会在目标端自动创建该 Topic。 |
      7. 单击 **下一步** 。
 3. 设置同步选项。

      1. 设置源端同步选项。

        ![源端](https://help-static-aliyun-doc.aliyuncs.com/assets/img/zh-CN/7653918061/p202799.png)

        | 参数 | 描述 |
        | --- | --- |
        | 源端选项 | 当前版本支持增量同步，您可以同步以下数据变更 DML： * Insert * Delete * Update |
        | 同步起始位点 | 指定同步某个时间节点之后的数据。 您可以选择时间节点，也可以直接输入时间戳。 |
      2. 设置目标端。

        设置是否打开 **生产者群组** 和 **是否允许消息追踪** 。如果打开 **生产者群组** 开关，请输入生产者群组。

        生产者群组用于表示发送消息应用，一个生产者群组可以发送多个 Topic 消息。
      3. 单击 **下一步** 。
 4. 预检查并启动数据同步任务。

   系统会自动完成数据同步的预检查。在 **预检查** 环节，OMS 会检测和目标端的连接情况。如果预检查报错，请排查并处理问题后，重新执行预检查，直至预检查成功。

   预检查成功后，请单击 **保存** 并 **启动任务** ，OMS 会直接创建数据同步任务。您也可以在左侧导航栏，单击 **数据同步** ，在 **数据同步** 页面手动启动该数据同步任务。

 上一篇 下一篇 ![有帮助](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) 咨询热线