场景描述

当需要查询以下信息时，可通过消费组详情页面操作：

• 查看在线消费者列表及其订阅的主题、分区。

• 查看消费组订阅的主题的消息堆积详细情况。

Kafka消息堆积的场景包括以下几个：

• 消费者处理延迟：当消费者的处理能力不足或出现故障时，无法及时消费Kafka中的消息，导致消息堆积。这可能是由于消费者的处理逻辑复杂、处理速度慢，或者消费者的资源不足等原因引起的。

• 网络故障：当Kafka集群与消费者之间的网络出现故障或不稳定时，可能导致消息传输延迟或中断。这会导致消息在Kafka中堆积，等待网络恢复后才能被消费。

• 生产者速度超过消费者：当生产者产生消息的速度超过消费者的处理速度时，会导致消息在Kafka中堆积。这可能是由于生产者的速度过快、消费者处理能力不足或者消费者故障等原因引起的。

• 消费者组调整：当消费者组中的消费者发生变化，如新增或退出消费者，会触发Kafka的重平衡操作。在重平衡期间，消费者无法消费消息，导致消息堆积。这通常发生在消费者扩展或故障恢复时。

• 高峰期消息涌入：在某些特定的时间段或事件发生时，可能会引发大量的消息涌入Kafka，超过消费者的处理能力。这会导致消息在Kafka中堆积，直到消费者能够跟上消息的处理速度。

消费者列表

操作步骤

（1）登录管理控制台。

（2）进入Kafka管理控制台。

（3）在实例列表页在操作列，目标实例行点击“管理”。

（4）点击“消费组管理”后，选择指定的消费组点击“详情”后打开如下页面。

列表展示了每个当前在线的消费者相关信息，包括消费者ID、消费者客户端地址、客户端ID、订阅消费的主题分区。

消息堆积

操作步骤

（1）登录管理控制台。

（2）进入Kafka管理控制台。

（3）在实例列表页在操作列，目标实例行点击“管理”。

（4）点击“消费组管理”后，选择指定的消费组点击“详情”后，点击“消息堆积”页卡后打开如下页面。

列表展示了当前消费组所订阅的每个主题的信息，包括主题名称、主题分区数、主题消息总堆积数。可点击表头根据Topic名称、分区数与总堆积数进行排序

（5）选择某个主题，点击左侧的展开按钮后，可查看当前主题每个分区的当前消费位点、消息堆积数以及消费者相关信息。