新建 RocketMQ 数据源

安全风险提醒

使用 OceanBase 数据传输服务，您可以选择自动添加或手动添加 OceanBase 数据传输服务的公网 IP 地址段，但可能存在安全风险。一旦使用本产品代表您已理解和确认其中可能存在的安全风险，并且您需要采取基本的安全防护措施，包括但不限于加强账号密码的复杂度、限制各网段开放的端口号、内部 API 采用鉴权方式进行通信，或者定期检查并限制无需访问的 IP 地址段。

OceanBase 数据传输服务会根据业务需求和安全风险等因素对自动添加的白名单或安全组进行调整操作（增加或删除），请勿将白名单或安全组中的 IP 地址段应用于非 OceanBase 数据传输服务的业务需求。如果因为您将其应用于其他业务需求导致的问题，不在 OceanBase 数据传输服务的 SLA 保障范围内。OceanBase 数据传输服务自动或手动添加的白名单或安全组，请参见 OceanBase 数据传输服务 添加白名单 模块的文档。

前提条件

• 数据传输已具备云资源访问权限。详情请参见 数据传输迁移角色授权。

• 已在 RocketMQ 实例中创建 Group。详情请参见 创建 Group。

• 已在 RocketMQ 实例中创建名称为 oms_test_topic 的 Topic。

• 开启 RocketMQ 实例 智能身份识别 访问控制中的 内网免身份识别。

  RocketMQ 实例默认使用 智能身份识别 访问控制类型，该类型默认对内网进行鉴权。如果未开启 内网免身份识别，则 VPC 接入点需要用户名和密码才能通过数据源测试连接。

使用限制

数据传输支持 RocketMQ 实例 V4.x 和 V5.x，包含商业版和社区版。

操作步骤

1. 登录 OceanBase 管理控制台。

2. 在左侧导航栏，单击 数据传输 > 数据源管理。

3. 在 数据源列表 页面，单击右上角的 新建数据源。

4. 在 新建数据源 对话框中，选择 数据源类型 为 RocketMQ。

5. 配置各项参数。

   参数	描述
   实例类型	目前仅支持 阿里云 RocketMQ 实例。
   数据源标识	建议使用中文、数字和字母的组合。名称中不能包含空格，长度不得超过 32 个字符。
   是否跨阿里云主账号	数据传输支持对不同阿里云主账号下的实例配置数据迁移或数据同步任务，实现跨阿里云主账号的数据迁移或数据同步。 您可以根据业务需求选择是否勾选。如果勾选，请输入对方阿里云主账号。如果不具备该主账号的权限，请先申请授权。授权详情请参见 申请跨账号授权。
   实例列表	从下拉列表中选择已创建的阿里云 RocketMQ 实例。
   RocketMQ 接入点信息	RocketMQ 的 <IP>:PORT 或者<域名>:PORT。
   AccessKey	您在阿里云账号管理控制台中创建的 AccessKey ID，用于身份认证。 您可以将鼠标悬停至页面右上角的用户头像，单击 AccessKey 管理，查看 AccessKey ID。
   SecretKey	您在阿里云账号管理控制台中创建的 AccessKey Secret，用于身份认证。 AccessKey Secret 只在创建时显示，不支持查看，请妥善保管。创建详情请参见 创建AccessKey。
   备注（可选）	数据源的备注信息。

6. 单击 测试连接，测试数据传输和数据库的网络连接。

   重要

   如果您未创建 oms_test_topic，将无法通过测试连接。

7. 测试连接通过后，单击 确定。

创建 Group

新建 RocketMQ 数据源时，您需要提前创建 defaultGroup，才能够通过测试连接。

1. 进入 RocketMQ 实例的详情页面。

   1. 登录 消息队列 RocketMQ 版管理控制台。

   2. 在左侧导航栏，单击 实例列表。

   3. 在 实例列表 页面，单击目标实例名称，进入 实例详情 页面。

2. 在左侧导航栏，单击 Group 管理。

3. 在 Group 管理 页面，单击 创建 Group，并配置各项参数。

   不同版本的 RocketMQ 实例，创建 Group 时需要配置的参数也不同。详情请参见 4.0 实例文档 或 5.0 实例文档。

   重要

   创建 Group 时，Group ID 必须设置为 defaultGroup。

4. 配置完成后，单击 确定。

5. 创建 Topic：oms_test_topic。

   1. 在目标实例的详情页面，单击左侧导航栏的 Topic 管理。

   2. 在 Topic 管理 页面，单击 创建 Topic。

   3. 在 创建 Topic 对话框，配置各项参数。

      参数	描述
      名称	oms_test_topic。
      付费方式	仅 RocketMQ 实例 4.x 版本创建 Topic 时显示该参数，且仅支持 按量付费。
      消息类型	RocketMQ 实例 4.x 版本支持 普通消息、事务消息、分区顺序消息、全局顺序消息 和 定时/延时消息。 RocketMQ 实例 5.x 版本支持 普通消息、顺序消息、定时/延时消息 和 事务消息。
      描述	长度不能超过 128 个字符。

   4. 配置完成后，单击 确定。