当出现消费堆积或倾斜时,您可以查看 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 存储的时间