创建 Group 并开始消费后,可以在消息队列 Kafka版控制台中查看指定实例下所有消费组的信息,包括 Group 订阅的 Topic、消息堆积量、消费组状态等。
已创建 Group,详细操作步骤请参考创建 Group。
概览统计:展示当前 Group 订阅的 Topic 数量、消息堆积量、当前 Group 的 ID 和状态。
分类 | 展示项 | 说明 |
---|---|---|
概览统计 | 订阅的Topic | 当前 Group 订阅的 Topic 数量。 |
消息堆积量 | 当前 Group 堆积的所有未消费消息量。消息堆积量为 0 表示无消息积压。 | |
Group信息 | Group ID | 当前 Group 的 ID。 |
状态 | 当前 Group 的状态。详细信息请参考Group 状态说明。
| |
描述 | Group 的简单描述。 |
消费状态:展示当前 Group 的消费状态,即每个订阅的 Topic 及其未消费消息数量。展开 Topic 的折叠列表还可以查看该 Topic 各个分区的 offset 消费情况。
说明
因为 offset 在消费端维护,offset 的位置和消费者提交 offset 的方式有关,所以 offset 信息是异步展示的,不一定代表当下实时的消费情况。
分类 | 展示项 | 说明 |
---|---|---|
Topic级别 | Topic | 当前 Group 订阅的 Topic 名称。 |
未消费消息数量 | 该 Topic 中堆积的未消费消息量。 | |
分区级别 | 分区编号 | 该 Topic 中的分区编号。 |
未消费消息数量 | 该分区中堆积的未消费消息量。 | |
提交offset位置 | 该分区中提交的已消费消息的位置。 | |
最小offset位置 | 该分区中最早消息的位置。 | |
最大offset位置 | 该分区中下一条消息的写入位置。分区消息的堆积数是最大 offset 位置减去提交 offset 的位置。 | |
消费者信息 | 该分区对应的消费者客户端的 IP 地址及端口号。 |
说明
使用 Kafka 自身的订阅消费管理时,Group 的状态包括 PreparingRebalance、CompletingRebalance、Stable 和 Empty。Logstash 等第三方开源组件也另外实现了一套独立的消费管理逻辑,对于这种客户端,通常只会存在 Empty 状态,且正常消费是在 Empty 状态下进行。
状态 | 说明 |
---|---|
PreparingRebalance | 消费组正在进行分区重分配,此过程会对消费组中每个消费者应该进行消费的分区进行计算。通常消费组加入或者退出一个消费组时,会触发此状态。 |
CompletingRebalance | 消费组完成了分区充分配的计算,等待将分配结果同步到各个消费者。 |
Stable | 分配结果同步到各个消费者后,消费组会进入此状态,开始进行消费处理。 |
Empty | 消费组当前无消费者正在消费。 说明 消息队列 Kafka版支持自动删除 Group(auto.delete.group) 功能,您可以设置后端服务是否自动删除 Empty 状态的消费组。设置方式请参考修改参数配置。 |