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

查看Topic被订阅的Consumer Group

  1. 登录消息队列Kafka版控制台
  2. 在顶部菜单栏,选择目标地域。
  3. 在左侧导航栏,单击Topic管理
  4. Topic管理页面,选择目标实例,找到目标Topic,在其操作列,选择更多 > 订阅关系
    订阅关系对话框,显示所有订阅该Topic的Consumer Group。订阅关系
  5. Consumer Group ID列表,找到目标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存储的时间