Querying a Consumer Group
Function
This API is used to query a specified consumer group.
URI
GET /v2/{project_id}/mqs/instances/{instance_id}/management/groups/{group}
| Parameter | Mandatory | Type | Description |
|---|---|---|---|
| project_id | Yes | String | Project ID |
| instance_id | Yes | String | Instance ID |
| group | Yes | String | Consumer group ID |
Request Parameters
None
Response Parameters
Status code: 200
| Parameter | Type | Description |
|---|---|---|
| [items] | Array of ShowGroupResp objects | OK. |
| Parameter | Type | Description |
|---|---|---|
| group | Array of ShowGroupEntity objects | Consumer group information |
| 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 joined the group. Stable: Members in the consumer group can consume messages normally. |
| coordinator_id | Integer | Coordinator ID |
| members | Array of MemberEntity objects | Consumer list |
| group_message_offsets | Array of GroupMessageOffsetsEntity objects | Consumer offset |
| assignment_strategy | String | Partition assignment policy |
| Parameter | Type | Description |
|---|---|---|
| host | String | Consumer address. |
| assignment | Array of AssignmentEntity objects | Details about the partition assigned to the consumer. |
| member_id | String | Consumer ID |
| client_id | String | Client ID |
| Parameter | Type | Description |
|---|---|---|
| topic | String | Topic name. |
| partitions | Array of integers | Partition list |
| Parameter | Type | Description |
|---|---|---|
| partition | Integer | Partition ID |
| lag | Integer | Number of remaining messages that can be consumed, 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
None
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.
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.