更新时间:2022-09-01 GMT+08:00
消费确认接口说明
功能介绍
确认已经消费指定消息。
- 在消费者消费消息期间,消息仍然停留在队列中,但消息从被消费开始的30秒内不能被该消费组再次消费,若在这30秒内没有被消费者确认消费,则MQS认为消息未消费成功,将可以被继续消费。
- endpoint为https://{rest_connect_address}:9292,通过指定实例接口查询rest_connect_address的IP地址。
URI
POST /v1/topic/{topic_name}/group/{group_name}/messages
参数 | 类型 | 必选 | 说明 |
|---|---|---|---|
topic_name | String | 是 | 主题名称。 |
group_name | String | 是 | 消费组名称。 |
请求消息
请求参数
参数 | 类型 | 必选 | 说明 |
|---|---|---|---|
messages | Array | 是 | 消息列表,数组大小不能超过10,且不能为空数组。 |
参数 | 类型 | 必选 | 说明 |
|---|---|---|---|
handler | String | 是 | 消息handler。 |
status | String | 是 | 消费状态。只能为success,或者fail。 |
请求示例
{
"messages": [
{
"handler": "NCMxMDAjMTgjMA==",
"status": "success"
}
]
} 响应消息
响应参数
参数 | 类型 | 说明 |
|---|---|---|
success | Integer | 确认消费成功的数目。 |
fail | Integer | 确认消费失败的数目。 |
响应示例
{
"success": 1,
"fail": 0
} 
