更新时间: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

表1 参数说明

参数

类型

必选

说明

topic_name

String

主题名称。

group_name

String

消费组名称。

请求消息

请求参数

参数

类型

必选

说明

messages

Array

消息列表,数组大小不能超过10,且不能为空数组。

表2 参数说明

参数

类型

必选

说明

handler

String

消息handler。

status

String

消费状态。只能为success,或者fail。

请求示例

{
   "messages": [
     {
       "handler": "NCMxMDAjMTgjMA==",
       "status": "success"
     }
   ]
}

响应消息

响应参数

参数

类型

说明

success

Integer

确认消费成功的数目。

fail

Integer

确认消费失败的数目。

响应示例

{
   "success": 1,
   "fail": 0
}

相关文档