当出现消费堆积或倾斜时，您可以查看Consumer Group和Topic之间的订阅关系，通过各个分区的消费进度进行判断。

查看Topic被订阅的Consumer Group

  1. 登录消息队列Kafka版控制台。
  2. 在顶部菜单栏，选择目标地域。
  3. 在左侧导航栏，单击Topic管理。
  4. 在Topic管理页面，选择目标实例，找到目标Topic，在其操作列，选择更多 > 订阅关系。
    在订阅关系对话框，显示所有订阅该Topic的Consumer Group。订阅关系
  5. 在Consumer Group列表，找到目标Consumer Group，在其右侧操作列，单击详情。

    在展开的表格，显示该Topic各个分区的消费详情。

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

查看Consumer Group订阅的Topic

  1. 登录消息队列Kafka版控制台。
  2. 在顶部菜单栏，选择目标地域。
  3. 在左侧导航栏，单击Consumer Group管理。
  4. 在Consumer Group管理页面，选择目标实例，找到目标Consumer Group，在其操作列单击消费状态。
    在消费状态对话框，显示该Consumer Group订阅的所有Topic以及各个Topic的堆积量和最近消费时间。消费状态
  5. 在Topic列表，找到目标Topic，在其右侧操作列，单击详情。
    在展开的表格，显示该Topic各个分区的消费详情。消费状态详情
    参数 说明
    分区ID 该Topic分区的ID。
    owner 实时订阅该Topic的在线Consumer。
    说明
    • 取值格式为<Client ID>_/<IP>。
    • 非在线消费端则无法查看owner信息。
    最大位点 该Topic在当前分区下的最大消息消费位点。
    消费位点 该Topic在当前分区下的消息消费位点。
    堆积量 当前分区下的消息堆积总量，即最大位点减去消费位点的值。
    注意 堆积总量是一个关键指标，如果发现堆积总量较大，则应用消费端可能产生了阻塞，或者消费速度跟不上生产速度。此时需要分析消费端的运行状况，尽力提升消费速度。详情请参见重置消费位点。
    最近消费时间 该Consumer Group消费的最近一条消息被发送到Broker存储的时间。