文档

新建 RocketMQ 数据源

更新时间:

配置好数据源是创建数据迁移或数据同步项目的前提。本文为您介绍如何在数据传输中新建 RocketMQ 数据源。

前提条件

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

  • 已在 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 实例

说明

商业版和社区版 VPC 内自建 RocketMQ 实例创建 Group 和 Topic 的方式相同。

  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
  • 本页导读 (0)