检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
numbers 全部代理ID。 broker_name String 节点名称。 请求示例 查询RocketMQ实例的代理列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/brokers 响应示例 状态码:
Integer 最大偏移量。 last_message_time Long 最后一条消息的时间。 请求示例 查询指定主题的消息数。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}/status
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 查询可用区信息成功。
权限集。 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 响应示例 状态码:
String RocketMQ配置目标值。 响应参数 无 请求示例 修改RocketMQ配置的参数,将文件保留时间修改为72小时。 PUT https://{endpoint}/v2/{project_id}/rocketmq/instances/{instance_id}/configs
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}
TransactionStatus.ROLLBACK:回滚事务,消息将被丢弃不允许消费。 TransactionStatus.UNKNOWN:无法判断状态,期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题: Python(TCP协议)
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
ketMQ实例状态变为“已冻结”,您将无法对处于保留期的包年/包月RocketMQ实例执行任何操作。 资源保留期到期未续费,释放且不可恢复。 如果包年/包月RocketMQ实例在保留期到期前仍未续费,那么RocketMQ实例将被释放,数据无法恢复。释放的实例会被彻底删除,不会进入回收站。
property_list 参数 参数类型 描述 name String 属性名称。 value String 属性值。 请求示例 查询消息。 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/messages
Long 已消费消息数。 last_message_time Long 最新消费消息的存储时间,unix毫秒时间戳格式。 请求示例 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups/{group}/topics