场景描述

操作步骤

（1）登录管理控制台。

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

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

（4）点击“监控信息”后，点击“消费者监控”。

（5）可以快速查询最近1小时、3小时、6小时、12小时、1天、3天、7天、14天内的监控信息，也可以自定义时间查询，最大支持14天内的监控数据查询。

（6）支持的监控指标有：消费组总堆积量、消费组Topic堆积量、消费组Rebalance次数

• 消费组总堆积量是指Kafka消息队列中所有消费者组累积的消息堆积量。堆积量表示尚未被消费的消息数量，它可以用来衡量系统的处理能力和消息消费的进度。管理员可以通过监控消费组总堆积量来了解整个系统的消息积压情况。如果消费组总堆积量持续增长，可能表示消费者组的消费速率跟不上消息的产生速率，系统无法及时处理消息。这可能导致消息积压，进而影响系统的实时性和稳定性。监控消费组总堆积量可以帮助管理员及时发现消息堆积问题，并采取相应的措施来解决。例如，可以增加消费者数量、提升消费者处理能力、调整消费者组的分区分配等，以缓解消息积压的情况。
• 消费组Topic堆积量是指特定消费组在某个Topic上的消息堆积量。堆积量表示尚未被该消费组消费的消息数量，可以用来评估消费组在该Topic上的消费进度和消费能力。通过监控消费组Topic堆积量，可以了解该消费组在特定Topic上的消息积压情况。如果堆积量持续增长，可能表示该消费组的消费速率跟不上消息的产生速率，导致消息堆积。这可能会影响系统的实时性和稳定性。管理员可以根据消费组Topic堆积量的监控结果，及时发现消息堆积问题，并采取相应的措施解决。例如，可以增加该消费组的消费者数量、提升消费者的处理能力，或者优化消费者的消费逻辑，以加快消息的消费速度，减少堆积量。

• 消费组的Rebalance次数是指在一段时间内，消费者组进行重新平衡的次数。重新平衡是指当消费者组的消费者数量发生变化（例如增加或减少消费者），或者消费者所订阅的Topic发生变化时，Kafka会重新分配分区给各个消费者，以保证消费者组的负载均衡。消费组的Rebalance次数可以反映系统中消费者组的稳定性和动态变化情况。较高的Rebalance次数可能意味着消费者组的变动频繁，这可能会导致一些消费者在重新平衡期间无法消费消息，从而影响系统的实时性和稳定性。管理员可以通过监控消费组的Rebalance次数来了解系统的消费者组变动情况。如果Rebalance次数过高，可能需要考虑优化消费者组的管理策略，例如减少消费者组的变动频率，或者调整消费者组的分区分配策略，以减少Rebalance的发生。