分布式消息服务KAFKA版-查询消费组信息:响应消息
响应消息
响应参数
参数说明见表2。
参数 |
类型 |
说明 |
---|---|---|
group_id |
String |
消费组名称。 |
state |
String |
消费组状态。包含以下状态:
|
coordinator_id |
Integer |
协调器编号 |
members |
Array of object members |
消费者列表。参数参见表3。 |
group_message_offsets |
Array of group_offsets |
消费进度。参数参见表4。 |
assignment_strategy |
String |
分区分配策略。 |
参数 |
类型 |
说明 |
---|---|---|
host |
String |
消费组consumer地址。 |
assignment |
Array of object assignment |
consumer分配到的分区信息。参数请参见表5。 |
member_id |
String |
消费组consumer的ID。 |
client_id |
String |
客户端ID。 |
参数 |
类型 |
说明 |
---|---|---|
topic |
String |
topic名称。 |
partition |
Integer |
分区编号。 |
message_current_offset |
Long |
当前消费进度。 |
message_log_end_offset |
Long |
最大消息位置(LEO)。 |
lag |
Long |
剩余可消费消息数,即消息堆积数。 |
响应示例
{ "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" } }
- kafka是什么_kafka介绍_分布式消息服务Kafka版
- 分布式消息服务Kafka版与分布式消息服务RocketMQ版的区别_Kafka与RocketMQ对比_Kafka与RocketMQ差异
- 分布式消息服务有哪些_分布式消息服务哪个好_分布式消息-华为云
- 分布式消息中间件实战_分布式消息实战_分布式消息-华为云
- 分布式消息服务优势_分布式消息服务_消息队列-华为云
- 分布式消息系统Kafka_分布式消息系统_分布式消息kafka可以解决什么问题-华为云
- 分布式消息中间件的作用_分布式消息中间件_分布式消息-华为云
- Kafka架构_Kafka如何实现负载均衡_Kafka数据存储方式-华为云
- RocketMQ的架构_RocketMQ的消息模式_分布式消息RocketMQ-华为云
- Kafka与其他消息队列的对比_什么是Kafka_分布式消息系统-华为云