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

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

前提条件

• 已创建 RocketMQ 数据源，详情请参见 添加 RocketMQ 数据源。

• 在您的 RocketMQ 实例中，您需要提前创建名称为 oms_test_topic 、属性为 分区顺序消息 的 Topic。

操作步骤

1. 新建同步链路。

   1. 登录 OMS 控制台。

   2. 在左侧导航栏，单击 数据同步 。

   3. 在 数据同步 页面，单击右上角的 新建同步链路 > 新建数据库到大数据同步链路 。

2. 选择源和目标。

   1. 在 选择源和目标 页面，选择 同步类型 为 OB → RocketMQ 。

   2. 设置 同步链路名 称 。

      说明

      同步链路名称支持中文、数字和英文字母的组合，且不得超过 500 个字符。

   3. 选择 表类型 和源端名称。 表类型 包括 单表 和 多表 。

   4. 选择需要同步的 数据表 。在左侧选中需要同步的数据表，单击 > ，将其添加至右侧列表中。

      

   5. 指定 分片列 。仅选择 表类型 为 单表 时，需要指定 分片列 。

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

      说明

      • 源端是 OceanBase Oracle 模式时，分片列处填写的字段名应全部转为大写字母。

      • 请保证分片列的正确性，分片列填写错误会导致数据同步任务失败。

   6. 设置 目标端 。

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

   7. 单击 下一步 。

3. 设置同步选项。

   1. 设置源端同步选项。

      

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

   2. 设置目标端。

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

      生产者群组用于表示发送消息应用，一个生产者群组可以发送多个 Topic 消息。

   3. 单击 下一步 。

4. 预检查并启动数据同步任务。

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

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