检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
group_perms 参数 参数类型 描述 name String 消费组名称。 perm String 权限。 请求示例 查询用户列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/users?offset=0&limit=10
Long 已消费消息数。 last_message_time Long 最新消费消息的存储时间，unix毫秒时间戳格式。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups/{group}/topics
property_list 参数 参数类型 描述 name String 属性名称。 value String 属性值。 请求示例 查询消息。 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/messages
from_transaction_check Boolean 是否为事务回查的响应。 请求示例 查询RocketMQ实例的消息轨迹。 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/trace
write_queue_num Number 写队列个数。 请求示例 查询指定RocketMQ实例的主题列表，查询数量为10，从offset=0开始查询。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics?offset=0&limit=10
响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 job_id String 规格变更任务ID。 请求示例 POST https://{endpoint}/v2/rocketmq/{project_id}/instances/{instance_id}/extend
error_code String 错误码。 error_message String 错误信息。 请求示例 重发死信消息。 POST https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/messa
expression String 订阅tag字符。 请求示例 查询指定消费组的消费者列表，查询数量为10，从offset=0开始查询。 GET https://{endpoint}/v2/rocketmq/{project_id}/instances/{instance_id}/groups/{group}/clients
消息ID。 error_code String 错误码。 error_message String 错误信息。 请求示例 消费验证。 POST https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/messages/resend
String 任务ID。 请求示例 批量修改消费组的参数，将consumer-group-test消费组的最大重试次数修改为16。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups { "groups"
partitions objects 分区信息。 表9 partitions 参数 参数类型 描述 name String 分区名称。 请求示例 GET https://{endpoint}/v1.0/{project_id}/instances/{instance_id}/ceshierarchy
JAVA_HOME=/root/jdk1.8.0_231 export PATH=$JAVA_HOME/bin:$PATH 下载测试工具。 wget https://dist.apache.org/repos/dist/release/rocketmq/5.1.4/rocketmq-all-5.1
分布式消息服务RocketMQ版提供了REST（Representational State Transfer）风格API，支持您通过HTTPS请求调用，调用方法请参见如何调用API。 终端节点 终端节点（Endpoint）即调用API的请求地址，不同服务不同区域的终端节点不同，
首尾字符不能为空格。 响应参数 无 请求示例 创建两个实例标签，标签名为key1、key2，值为value1、value2。 POST https://{endpoint}/v2/{project_id}/rocketmq/{instance_id}/tags/action {
e.printStackTrace(); System.out.println(e.getHttpStatusCode()); System.out.println(e.getRequestId());
name String 属性名称。 value String 属性值。 请求示例 导出主题中指定消息ID和Key的死信消息。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/messages/export
默认情况下，新建的IAM用户没有任何权限，您需要将其加入用户组，并给用户组授予策略或角色，才能使用户组中的用户获得相应的权限，这一过程称为授权。授权后，用户就可以基于已有权限对云服务进行操作。 权限根据授权的精细程度，分为角色和策略。角色以服务为粒度，是IAM最初提供的一种根据用户的工作职
投递时间与客户端设置的投递时间之间可能存在偏差，以服务端时间为准。 设置定时消息的投递时间后，依然受消息老化时间限制，默认消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。
com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy 发送顺序消息 参考如下示例代码（以下加粗内容需
事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务回滚。服务端在一段时间后如果一直收不到提交或回滚，则发起回查，生产者在收到回查后重新发送事务提交或回滚。消息只有在提交之后才投递给消费者，消费者对回滚的消息不可见。 收发事务消息前，请参考收集
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
