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

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

前提条件

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

• 您需要开启 Sybase 源端表的可复制功能，方式如下：

  通过对需要复制至备用数据库中的每个表执行 sp_setreptable 系统过程，标记各个需要复制数据更改的表：sp_setreptable <table_name>, 'true'。

操作步骤

1. 新建同步链路。

   1. 登录 OMS 控制台。

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

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

2. 选择源和目标。

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

   2. 设置 同步链路名 称 。

      说明

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

   3. 从 源端 下拉列表中选择 Sybase 数据源。

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

      由于 Sybase 数据源要求必须录入数据库的名称，界面仅提供一个 Database 供您选择，且仅展示 Table。如果您需要选择整库，请单击数据库名称左边的复选框，默认勾选全部表。

   5. 设置 目标端 。

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

   6. 单击 下一步 。

3. 设置同步选项。

   1. 设置源端同步选项。

      不允许过滤 Sybase 增量的 DML 类型，默认全部勾选且不可编辑。

   2. 设置目标端。

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

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

   3. 单击 下一步 。

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

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

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