检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
numbers 全部代理ID。 broker_name String 节点名称。 请求示例 查询RocketMQ实例的代理列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/brokers 响应示例 状态码:
由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ 首尾字符不能为空格。 请求示例 查询实例标签。 GET https://{endpoint}/v2/{project_id}/rocketmq/{instance_id}/tags 响应示例 状态码: 200
Integer 最大偏移量。 last_message_time Long 最后一条消息的时间。 请求示例 查询指定主题的消息数。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}/status
权限集。 consume_orderly Boolean 是否按顺序消费。 请求示例 查询RocketMQ实例的消费组列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups 响应示例 状态码:
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}
String RocketMQ配置目标值。 响应参数 无 请求示例 修改RocketMQ配置的参数,将文件保留时间修改为72小时。 PUT https://{endpoint}/v2/{project_id}/rocketmq/instances/{instance_id}/configs
RocketMQ-Spring的使用 本文介绍如何使用RocketMQ-Spring连接华为云RocketMQ实例进行消息的生产和消费。相关代码您可以从rocketmq-springboot-demo中获取。 下文所有RocketMQ的配置信息,如实例连接地址、Topic名称、用户信息等,请参考收集连接信息获取。
IP白名单。 admin Boolean 是否为管理员。 perm String 权限。 请求示例 查询主题的授权用户列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}/accesspolicy
remain_time Long 剩余时间。 ipv6_enable Boolean 是否支持IPv6。 请求示例 查询可用区信息。 GET https://{endpoint}/v2/available-zones?engine=reliability 响应示例 状态码: 200 查询可用区信息成功。
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}
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