更新时间:2024-10-10 GMT+08:00

Kafka消息堆积了怎么办?

问题现象:实例的监控指标“堆积消息数”产生了告警。

处理方法1:

  1. 登录Kafka实例控制台,单击产生告警的实例名称,进入实例详情页。
  2. 在左侧导航栏,单击“监控与告警 > 监控详情”,进入监控页面。
  3. 在“消费组”页签中,查看“消息堆积数(消费组可消费消息数)”,找出消息堆积的消费组。
  4. 在左侧导航栏,单击“消费组管理”,进入消费组列表页面。
  5. 查看消息堆积的消费组是否有消费者在消费,如果有,让业务方加快消费效率,如果没有,让客户酌情删掉不使用的消费组。

处理方法2:

  1. 登录Kafka实例控制台,单击产生告警的实例名称,进入实例详情页。
  2. 在左侧导航栏,选择“分析与诊断 > 消息积压诊断”,进入消息积压诊断页面。
  3. 选择需要诊断的消费组名称和Topic名称,单击“诊断前检查”。
  4. 诊断前检查成功后,如果“消息积压情况”显示有消息积压,并且消费组正在以非assign方式消费消息中,单击“开始诊断”。
  5. 诊断成功后,在诊断记录所在行,单击“查看详情”,进入“诊断详情”页面,查看导致消息堆积的可能原因、受影响的分区或者broker,以及解决消息堆积的建议,根据建议处理消息堆积。