Help Center> Distributed Message Service for Kafka> API Reference> APIs V2 (Recommended)> Instance Management> Querying Consumer Group Details
View PDF

Querying Consumer Group Details

Function

This API is used to query consumer group details.

Debugging

You can use API Explorer to debug this API.

URI

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

Table 1 Path parameters

Parameter

Mandatory

Type

Description

project_id

Yes

String

Project ID.

instance_id

Yes

String

Instance ID.

group

Yes

String

Consumer group name.

Request Parameters

None

Response Parameters

Status code: 200

Table 2 Response body parameters

Parameter

Type

Description

group

group object

Consumer group information.
Table 3 group

Parameter

Type

Description

group_id

String

Consumer group name.

state

String

Consumer group status. The value can be:

  • Dead: The consumer group has no members and no metadata.

  • Empty: The consumer group has metadata but has no members.

  • PreparingRebalance: The consumer group is to be rebalanced.

  • CompletingRebalance: All members have jointed the group.

  • Stable: Members in the consumption group can consume messages normally.

coordinator_id

Integer

Coordinator ID.

members

Array of members objects

Consumer list.

group_message_offsets

Array of group_message_offsets objects

Consumer offset.

assignment_strategy

String

Partition assignment policy.
Table 4 members

Parameter

Type

Description

host

String

Consumer address.

assignment

Array of assignment objects

Details about the partition assigned to the consumer.

member_id

String

Consumer ID.

client_id

String

Client ID.
Table 5 assignment

Parameter

Type

Description

topic

String

Topic name.

partitions

Array of integers

Partition list.
Table 6 group_message_offsets

Parameter

Type

Description

partition

Integer

Partition number.

lag

Integer

Number of remaining messages that can be retrieved, that is, the number of accumulated messages.

topic

String

Topic name.

message_current_offset

Integer

Consumer offset.

message_log_end_offset

Integer

Log end offset (LEO).

Example Requests

GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}

Example Responses

Status code: 200

The consumer group details are queried successfully.

{
  "group" : {
    "members" : [ {
      "host" : "/172.31.1.102",
      "assignment" : [ {
        "topic" : "test",
        "partitions" : [ 0, 1, 2 ]
      } ],
      "member_id" : "consumer-1-6b8ee551-d499-47d4-9beb-ba1527496785",
      "client_id" : "consumer-1"
    } ],
    "state" : "STABLE",
    "group_id" : "test-consumer-group",
    "coordinator_id" : 2,
    "group_message_offsets" : [ {
      "partition" : 0,
      "lag" : 31396,
      "topic" : "test",
      "message_current_offset" : 935,
      "message_log_end_offset" : 32331
    }, {
      "partition" : 0,
      "lag" : 0,
      "topic" : "aaaa",
      "message_current_offset" : 0,
      "message_log_end_offset " : 0
    }, {
      "partition" : 1,
      "lag" : 31279,
      "topic" : "test",
      "message_current_offset" : 1058,
      "message_log_end_offset " : 32337
    }, {
      "partition" : 1,
      "lag" : 0,
      "topic" : "aaaa",
      "message_current_offset" : 0,
      "message_log_end_offset" : 0
    }, {
      "partition" : 2,
      "lag" : 31603,
      "topic" : "test",
      "message_current_offset" : 739,
      "message_log_end_offset" : 32342
    } ],
    "assignment_strategy" : "range"
  }
}

Status Codes

Status Code

Description

200

The consumer group details are queried successfully.

Error Codes

See Error Codes.

Parent topic: Instance Management