检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
修改用户参数 功能介绍 修改用户参数。 调用方法 请参见如何调用API。 URI PUT /v2/{project_id}/instances/{instance_id}/users/{user_name} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是
参数管理 查询RocketMQ配置 修改RocketMQ配置 父主题: API V2(推荐)
configs 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 rocketmq_configs
gs 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 rocketmq_configs
在左侧导航栏,选择“元数据迁移”,进入迁移任务列表页面。 单击“创建迁移任务”,弹出“创建迁移任务”对话框。 参考表3,设置迁移任务的参数。 表3 迁移任务参数说明 参数 说明 任务类型 选择“自建RocketMQ上云”。 任务名称 您可以自定义迁移任务的名称,用于区分不同的迁移任务。 任务名称命名规则如下:
topic-test -p "hello rocketmq" 使用Ctrl+C命令退出。 运行消费普通消息示例。 sh mqadmin consumeMessage -n "${连接地址}" -t ${Topic名称} 参数说明如下: 连接地址:表示RocketMQ实例的“连接地址”(内网访问)/“公网连接地址”(公网访问)。
tMQ实例的基本信息页面,查看RocketMQ实例的详细信息。 表2和表3为连接实例的相关参数,其他参数,请查看页面显示。 表2 连接信息(分布式消息服务RocketMQ版4.8.0) 参数 说明 内网连接地址 未开启公网访问时,连接实例的地址。 公网访问 公网访问状态。单击“公网访问”后的,开启/关闭公网访问。
关联的代理列表。 name 否 String 待修改参数的消费组(消费组名称不支持修改)。 retry_max_time 是 Integer 最大重试次数,取值范围为1~16。 响应参数 状态码: 204 表3 响应Body参数 参数 参数类型 描述 - AnyType 操作成功。 请求示例
关闭 关闭 创建如表2所示Topic,创建步骤请参考创建Topic。 表2 Topic参数 名称 消息类型 topic-01 普通 创建如表3所示消费组,创建步骤请参考创建消费组。 表3 消费组参数 名称 最大重试次数 是否允许以广播模式消费 是否顺序消费 group-01 16 否
创建Topic(RocketMQ实例4.8.0版本) 图2 创建Topic(RocketMQ实例5.x版本) 表1 Topic参数说明(RocketMQ实例4.8.0版本) 参数 说明 Topic名称 您可以自定义Topic名称,用于区分不同的Topic。 Topic名称命名规则如下: 长度为3~64个字符。
/groups 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 groups 否
息中间件服务。 本文档提供了分布式消息服务RocketMQ版API的描述、语法、参数说明及样例等内容。 分布式消息服务RocketMQ版持续增加新的功能,将不可避免对现有接口有所调整,比如增加响应参数。 为了减少接口变更带来的影响,除了分布式消息服务RocketMQ版自身尽量做到
单击待查看的消费组名称,进入消费组详情页面。 在详情页上方可以查看消费组名称、关联代理(仅RocketMQ实例4.8.0版本存在此参数)、最大重试次数、描述、顺序消费(仅RocketMQ实例5.x版本存在此参数)和广播消费的配置。 在详情页下方可以查看到消费组信息,及消费组订阅的所有Topic、授权信息以及订阅关系。
创建如表2所示Topic,创建步骤请参考创建Topic。 表2 Topic参数 名称 权限 关联代理 队列个数 topic-01 发布+订阅 broker-0 8 创建如表3所示消费组,创建步骤请参考创建消费组。 表3 消费组参数 名称 关联代理 最大重试次数 是否允许以广播模式消费 group-01
"hello rocketmq" 使用Ctrl+C命令退出。 运行消费普通消息示例。 JAVA_OPT=-Dtls.enable=true sh mqadmin consumeMessage -n "${连接地址}" -t ${Topic名称} 参数说明如下: 连接地址:表示RocketM
表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 topic 是 String 主题名称。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述
0_321”为JDK的安装路径,请根据实际情况修改。 按“Esc”退出编辑模式并执行以下命令保存环境变量文件。 :wq 执行以下命令使环境变量生效。 source .bash_profile 执行以下命令查看JDK是否安装成功。 java -version 显示信息中包含如下信息则表示JDK安装成功。
选择以下任意一种方法修改Topic参数。 在待修改的Topic所在行,单击“编辑”,弹出“编辑Topic”页面。 单击待修改的Topic名称,进入Topic详情页面。在页面右上角,单击“编辑”,弹出“编辑Topic”页面。 修改如表1所示配置信息。 表1 Topic参数说明 参数 说明 权限 RocketMQ实例的版本为4
准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go
准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go