调用 DescribeConsumedPartitions 接口查看消费组订阅的指定 Topic 的分区信息。

使用说明

此接口用于查看消费组订阅的指定 Topic 中每个分区的基本信息，包括分区的编号、消费者、消费进度等。

调试

请求参数

下表仅列出该接口特有的请求参数和部分公共参数。更多信息请见公共参数。

返回参数

下表仅列出本接口特有的返回参数。更多信息请参见返回结构。

请求示例

POST /?Action=DescribeConsumedPartitions&Version=2022-05-01 HTTP/1.1
Content-Type: application/json
Host: kafka.volcengineapi.com
X-Date: 20210328T100802Z
Authorization: HMAC-SHA256 Credential=AK********/20210328/cn-beijing/Kafka/request, SignedHeaders=x-date, Signature=********

{
  "InstanceId": "kafka-cnng1si21igu****",
  "PageNumber": 1,
  "PageSize": 20,
  "GroupId":"Group",
  "TopicName": "test"
}

返回示例

{
    "ResponseMetadata": {
        "RequestId": "20230321113657C9E60632E1D4F61E5BC5",
        "Action": "DescribeConsumedPartitions",
        "Version": "2022-05-01",
        "Service": "Kafka",
        "Region": "cn-beijing"
    },
    "Result": {
        "ConsumedPartitionsInfo": [
            {
                "Accumulation": 14733811,
                "ConsumedClient": "consumer-1/192.168.xxx.xx",
                "ConsumedOffset": 5384592589,
                "EndOffset": 5399326400,
                "PartitionId": 0,
                "StartOffset": 5383336144
            },
            ......
            {
                "Accumulation": 14840853,
                "ConsumedClient": "consumer-1/192.168.xxx.xx",
                "ConsumedOffset": 5384490996,
                "EndOffset": 5399331849,
                "PartitionId": 11,
                "StartOffset": 5383905142
            }
        ],
        "Total": 12
    }
}

错误码

下表为您列举了该接口与业务逻辑相关的错误码。公共错误码请参见公共错误码文档。