检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
创建消费组或批量删除消费组 批量修改消费组 删除指定消费组 查询指定消费组 修改消费组 查询消费列表或详情 重置消费进度 查询消费者列表 父主题： API V2（推荐）
调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/metadata 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 instance_id
元数据迁移 新建元数据迁移任务 查询实例下所有迁移任务或查询指定迁移任务信息 删除元数据迁移任务 父主题： API V2（推荐）
规格变更管理 查询实例的扩容规格列表 实例规格变更 父主题： API V2（推荐）
权要求，管理员可以创建自定义策略，并通过给用户组授予自定义策略来进行精细的访问控制。策略支持的操作与API相对应，授权项列表说明如下： 权限：允许或拒绝某项操作。 对应API接口：自定义策略实际调用的API接口。 授权项：自定义策略中支持的Action，在自定义策略中的Actio
查询产品规格列表 功能介绍 查询相应引擎的产品规格列表。 调用方法 请参见如何调用API。 URI GET /v2/{engine}/products 表1 路径参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎的类型。支持的类型为rocketmq。 表2
查询RocketMQ产品规格核数 功能介绍 查询RocketMQ产品规格核数。 调用方法 请参见如何调用API。 URI GET /v2/rocketmq/products/cores 请求参数 无 响应参数 状态码： 200 表1 响应Body参数 参数 参数类型 描述 core_nume
调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/groups 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 instance_id
queue_id 队列ID。 queue_offset 在队列中的偏移量。 重新投递死信消息 死信消息由于某些原因无法正常被消费者消费，请排查相关原因并解决，然后在控制台重新投递死信消息给消费者消费。 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
使用ACL权限访问 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。 约束与限制 RocketMQ TCP协议的Python SDK只支持Linux系统。 生产者增加用户认证信息 普通消息、顺序消息和定时消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。
使用ACL权限访问 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖： 使用Maven方式引入依赖。 <dependency>
查询可用区信息 功能介绍 在创建实例时，需要配置实例所在的可用区ID，可通过该接口查询可用区的ID。 调用方法 请参见如何调用API。 URI GET /v2/available-zones 请求参数 无 响应参数 状态码： 200 表1 响应Body参数 参数 参数类型 描述 region_id
使用ACL权限访问 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息。 生产者增加用户认证信息 普通消息、顺序消息和定时消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。 import ( "context" "fmt" "os"
进行测试前，您需要先构建如下的测试环境： 购买如表1所示实例，购买步骤请参考购买实例。 表1 实例参数 名称 规格 存储空间 ACL访问 公网访问 rocketmq-01 rocketmq.b2.large.4 超高I/O 300GB 关闭 关闭 rocketmq-02 rocketmq
），即为未开启SSL。 前提条件 已创建RocketMQ实例，并记录实例详情中的“连接地址”（内网访问）/“公网连接地址”（公网访问）。内网访问的连接端口为8100，公网环境下访问的连接端口为8200。 客户端和RocketMQ实例之间网络已互通，具体网络要求参见连接RocketMQ网络要求页面。
也可以通过查询VPC列表API查询。 subnet_id：VPC内子网的网络ID。您可以在虚拟私有云控制台查询，也可以通过查询子网列表API查询。 security_group_id：安全组ID。您可以在虚拟私有云控制台查询，也可以通过查询安全组列表API查询。 available_zones：创建节点到指定的AZ
应用示例 批量创建Topic
附录 状态码 错误码 实例状态说明 获取项目ID 获取账号名和账号ID
修订记录 发布日期 修订记录 2024-12-20 本次变更如下： 新增查询产品规格列表、查询RocketMQ产品规格核数、查询实例节点和重启指定实例接口。 2024-09-04 本次变更如下： 更新查询RocketMQ配置的响应示例。 2024-07-05 本次变更如下： 新增应用示例批量创建Topic。
在待删除的Topic或者消费组所在行，单击“删除”。 勾选需要删除的Topic或者消费组，单击左上角的“批量删除”。 通过用户访问服务端 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息，具体操作如下： Java代码示例 Go代码示例 Python代码示例 编辑用户
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
