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