更新时间:2024-04-08 GMT+08:00

查询消费列表或详情

功能介绍

查询消费列表或详情。

URI

GET /v2/{project_id}/instances/{instance_id}/groups/{group}/topics

表1 路径参数

参数

是否必选

参数类型

描述

project_id

String

项目ID,获取方式请参见获取项目ID

instance_id

String

实例ID。

group

String

消费组名称。

表2 Query参数

参数

是否必选

参数类型

描述

topic

String

待查询的topic,不指定时查询topic列表,指定时查询详情。

limit

Integer

当次查询返回的最大个数,默认值为10,取值范围为1~50。

最小值:1

最大值:50

缺省值:10

offset

Integer

偏移量,表示从此偏移量开始查询, offset大于等于0。

最小值:0

缺省值:0

请求参数

响应参数

状态码: 200

表3 响应Body参数

参数

参数类型

描述

topics

Array of strings

Topic列表(当查询topic消费“列表”时才显示此参数)。

total

Integer

Topic总数(当查询topic消费“列表”时才显示此参数)。

lag

Long

消费堆积总数

max_offset

Long

消息总数

consumer_offset

Long

已消费消息数

brokers

Array of Brokers objects

Topic关联代理(当查询topic消费“详情”才显示此参数)。

表4 Brokers

参数

参数类型

描述

broker_name

String

Topic关联代理名称

queues

Array of Queue objects

关联代理的队列详情

表5 Queue

参数

参数类型

描述

id

Integer

队列ID

lag

Long

队列消费堆积总数

broker_offset

Long

队列消息总数

consumer_offset

Long

已消费消息数

last_message_time

Long

最新消费消息的存储时间,unix毫秒时间戳格式

请求示例

GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups/{group}/topics?topic=test0001

响应示例

状态码: 200

查询消费列表或详情成功。

  • 查询消费组的topic列表成功。

    {
      "topics" : [ "topic-test" ],
      "total" : 1
    }
  • 查询消费组详情成功。

    {
      "lag" : 0,
      "max_offset" : 1,
      "consumer_offset" : 1,
      "brokers" : [ {
        "broker_name" : "broker-0",
        "queues" : [ {
          "id" : 0,
          "lag" : 0,
          "broker_offset" : 0,
          "consumer_offset" : 0,
          "last_message_time" : 0
        }, {
          "id" : 1,
          "lag" : 0,
          "broker_offset" : 1,
          "consumer_offset" : 1,
          "last_message_time" : 1679398537088
        }, {
          "id" : 0,
          "lag" : 0,
          "broker_offset" : 0,
          "consumer_offset" : 0,
          "last_message_time" : 0
        } ]
      } ]
    }

状态码

状态码

描述

200

查询消费列表或详情成功。

错误码

请参见错误码