新建 RocketMQ 数据源

安全风险提醒

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

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

前提条件

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

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

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

使用限制

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

• VPC 内自建 RocketMQ 实例对于网络的处理：安装 RocketMQ 实例的 ECS 的安全组需要添加对应 VPC 的网段，放开 RocketMQ 实例的 namesvr 和 broker 的所有端口。

操作步骤

1. 登录 OceanBase 管理控制台。

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

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

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

5. 配置各项参数。从 实例类型 下拉列表选择不同的 实例类型 后，下方会自动显示对应的表单。

   实例类型	参数	描述
   阿里云 RocketMQ 实例	实例列表	从下拉列表中选择已创建的阿里云 RocketMQ 实例。
   VPC 内自建 RocketMQ 实例	VPC	从下拉列表中选择用户申请公有云 VPC 的唯一 ID。
   	交换机	交换机（vSwitch）是组成专有网络 VPC 的基础网络模块，用于连接不同的云资源实例。详情请参见 交换机概述。
   共有参数 公网 RocketMQ 实例中包含所有共有参数	数据源标识	建议使用中文、数字和字母的组合。名称中不能包含空格，长度不得超过 32 个字符。
   	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，才能够通过测试连接。

阿里云 RocketMQ 实例

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. 配置完成后，单击 确定。

VPC 内自建 RocketMQ 实例

1. 进入机器的 RocketMQ 目录，执行下述命令，即可创建 defaultGroup。

   ./bin/mqadmin updateSubGroup -n 10.10.10.1:2882 -c DefaultCluster -g defaultGroup

2. 执行下述命令，创建 Topic：oms_test_topic。

   ./bin/mqadmin updateTopic -t oms_test_topic -n 10.10.10.1:2882 -c DefaultCluster