检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
String 元数据迁移任务状态。 type String 元数据迁移类型。 请求示例 查询RocketMQ实例下所有迁移任务。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/metadata 响应示例 状态码:
group_perms 参数 参数类型 描述 name String 消费组名称。 perm String 权限。 请求示例 查询用户详情。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/users/{user_name}
IP白名单。 admin Boolean 是否为管理员。 perm String 权限。 请求示例 查询消费组的授权用户列表。 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/group
队列ID。 timestamp_offset Long 重置消费进度。 请求示例 重置topic_01主题的消费进度到指定时间点。 POST https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/group
描述 - AnyType 操作成功。 请求示例 修改consumer-group-test消费组的参数,最大重试次数修改为16。 PUT https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups/{group}
简要说明 详细介绍 容灾和多活 根据对数据与服务的不同可靠性要求,您可以选择在单可用区内(单机房)部署RocketMQ实例,或跨可用区(同城灾备)部署。 在单可用区或多可用区中部署实例 副本冗余 使用一主两备架构,备节点通过数据同步的方式保持数据一致。当网络发生异常或节点故障时,
支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。 用户开通云审计服务并创建和配置追踪器后,CTS可记录DMS for RocketMQ的管理事件用于审计。 CTS的详细介绍和开通配置方法,请参见CTS快速入门。 CTS支持追踪的DMS for RocketMQ管理事件列表,请参见云审计服务支持的DMS
IP白名单。 admin Boolean 是否为管理员。 perm String 权限。 请求示例 查询主题的授权用户列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}/accesspolicy
全托管服务:分布式消息服务RocketMQ版提供自动部署与完备的运维系统和售后服务,提供包括监控告警在内的多种运维手段,业务无需过多关注分布式消息服务RocketMQ版的部署与运维工作,可以专注于自身业务的开发。 低延迟:基于华为云网络部署,在内网访问可达微秒级时延。 弹性高可靠:基于
查看RocketMQ消费组详情 消费组创建成功后,可在控制台查看消费组的相关配置和状态信息。 前提条件 已创建消费组。 查看RocketMQ消费组详情 登录管理控制台。 在管理控制台左上角单击,选择区域。 不同区域的云服务产品之间内网互不相通。请就近选择靠近您业务的区域,可减少网络时延,提高访问速度。
property_list 参数 参数类型 描述 name String 属性名称。 value String 属性值。 请求示例 查询消息。 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/messages
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
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
死信队列用于处理无法被正常消费的消息。 一条消息初次消费失败会被重试消费,若重试次数达到最大值(默认16次,在创建RocketMQ消费组中可配置)时,依然消费失败,则其将被投递到该消费者对应的特殊队列(即死信队列)中,这种消息被称为死信消息。 死信消息具有如下特性: 不会再被消费者正常消费。