当消费堆积或倾斜时,您可以查看Group和Topic之间的订阅关系,查看Topic各个分区的消费进度,了解消息的堆积总量,及时调整业务,预防风险。

查看Topic被订阅的Group

  1. 登录消息队列Kafka版控制台
  2. 概览页面的资源分布区域,选择地域。
  3. 实例列表页面,单击目标实例名称。
  4. 在左侧导航栏,单击Topic管理
  5. Topic管理页面,找到目标Topic,在其操作列,选择更多 > 订阅关系
    Topic 详情页面的订阅关系页签,显示所有订阅该Topic的Group订阅关系
  6. 订阅当前 Topic 的在线 Group 的列表中,找到目标Group,在其右侧操作列,单击消费详情

    在消费详情列表,显示该Topic各个分区的消费详情。

    消费详情
    参数 说明
    分区 ID 该Topic分区的ID。
    客户端 实时订阅该Topic的在线Consumer。
    说明
    • 取值格式为<Client ID>_/<IP>
    • 非在线消费端则无法查看客户端信息。
    最大位点 该Topic在当前分区下的最大消息消费位点。
    消费位点 该Topic在当前分区下的消息消费位点。
    堆积量 当前分区下的消息堆积总量,即最大位点减去消费位点的值。
    注意 堆积总量是一个关键指标,如果发现堆积总量较大,则应用消费端可能产生了阻塞,或者消费速度跟不上生产速度。此时需要分析消费端的运行状况,提升消费速度。更多信息,请参见重置消费位点

查看Group订阅的Topic

  1. 登录消息队列Kafka版控制台
  2. 概览页面的资源分布区域,选择地域。
  3. 实例列表页面,单击目标实例名称。
  4. 在左侧导航栏,单击Group 管理
  5. Group 管理页面,找到目标Group,在其操作列,选择更多 > 消费状态
    Group 详情消费状态页签,显示该Group订阅的所有Topic以及各个Topic的堆积量最近消费时间消费状态
  6. Topic列表,找到目标Topic,在其右侧操作列,单击消费详情
    消费详情列表,显示该Group在相应Topic的各个分区的消费详情。消费详情