You need to enable JavaScript to run this app.
导航
查看 Group 消费状态
最近更新时间:2024.03.07 20:25:46首次发布时间:2021.08.30 16:20:22

创建 Group 并开始消费后,可以在消息队列 Kafka版控制台中查看指定实例下所有消费组的信息,包括 Group 订阅的 Topic、消息堆积量、消费组状态等。

前提条件

已创建 Group,详细操作步骤请参考创建 Group

操作步骤

  1. 登录消息队列 Kafka版控制台
  2. 在顶部菜单栏中选择地域,并在选择左侧导航栏中单击实例列表
  3. 找到目标实例,单击实例名称。
  4. 在顶部页签栏中单击Group管理,页签中展示当前实例下的 Group 列表。
    当 Group 数量较多时,可以在页签右上角通过 Group ID 搜索 Group,查看指定 Group 的状态,支持模糊搜索。
  5. 单击 Group ID,查看指定 Group 的消费状态。
    Group 详情页展示当前 Group 的消费状态,包括概览统计和消费状态区域。
    • 概览统计:展示当前 Group 订阅的 Topic 数量、消息堆积量、当前 Group 的 ID 和状态。

      分类

      展示项

      说明

      概览统计

      订阅的Topic

      当前 Group 订阅的 Topic 数量。

      消息堆积量

      当前 Group 堆积的所有未消费消息量。消息堆积量为 0 表示无消息积压。

      Group信息

      Group ID

      当前 Group 的 ID。

      状态

      当前 Group 的状态。详细信息请参考Group 状态说明

      • PreparingRebalance:消费组正在进行分区重分配。
      • CompletingRebalance:消费组完成了分区重分配的计算。
      • Stable:分配结果同步到各个消费者后,消费组会进入此状态,开始进行消费处理。
      • Empty:消费组当前无消费者正在消费。

      描述

      Group 的简单描述。

    • 消费状态:展示当前 Group 的消费状态,即每个订阅的 Topic 及其未消费消息数量。展开 Topic 的折叠列表还可以查看该 Topic 各个分区的 offset 消费情况。

      说明

      因为 offset 在消费端维护,offset 的位置和消费者提交 offset 的方式有关,所以 offset 信息是异步展示的,不一定代表当下实时的消费情况。

      分类

      展示项

      说明

      Topic级别

      Topic

      当前 Group 订阅的 Topic 名称。

      未消费消息数量

      该 Topic 中堆积的未消费消息量。

      分区级别

      分区编号

      该 Topic 中的分区编号。

      未消费消息数量

      该分区中堆积的未消费消息量。

      提交offset位置

      该分区中提交的已消费消息的位置。

      最小offset位置

      该分区中最早消息的位置。

      最大offset位置

      该分区中下一条消息的写入位置。分区消息的堆积数是最大 offset 位置减去提交 offset 的位置。

      消费者信息

      该分区对应的消费者客户端的 IP 地址及端口号。

Group 状态说明

说明

使用 Kafka 自身的订阅消费管理时,Group 的状态包括 PreparingRebalance、CompletingRebalance、Stable 和 Empty。Logstash 等第三方开源组件也另外实现了一套独立的消费管理逻辑,对于这种客户端,通常只会存在 Empty 状态,且正常消费是在 Empty 状态下进行。

状态

说明

PreparingRebalance

消费组正在进行分区重分配,此过程会对消费组中每个消费者应该进行消费的分区进行计算。通常消费组加入或者退出一个消费组时,会触发此状态。
此状态是一个临时状态,正常情况下只会存在一个极短的时间。若此状态长期存在,极大可能消费组中存在异常的消费者,不断退出加入。
此状态下的消费组不能进行正常消费。

CompletingRebalance

消费组完成了分区充分配的计算,等待将分配结果同步到各个消费者。
此状态是一个临时状态,与 PreparingRebalance 相同,消费组不应长时间处于此状态。
此状态下的消费组不能进行正常消费。

Stable

分配结果同步到各个消费者后,消费组会进入此状态,开始进行消费处理。
此状态下的消费组可以进行正常消费。

Empty

消费组当前无消费者正在消费。
此状态的消费组中可能存在历史有效的消费进度,该消费进度会在到期后被后台服务自动清除。

说明

消息队列 Kafka版支持自动删除 Group(auto.delete.group) 功能,您可以设置后端服务是否自动删除 Empty 状态的消费组。设置方式请参考修改参数配置