更新时间:2025-12-26 GMT+08:00
分享

配置积压告警规则

操作场景

在Kafka消息队列使用场景中,消息积压可能导致系统性能下降或数据丢失风险。如果用户无法及时发现积压问题,可能影响业务连续性。您可以通过KafkaUI查看并配置积压告警规则,当消息积压达到预设阈值时,系统将自动上报“ALM-38018 Kafka消息积压”告警,帮助您及时发现并处理异常情况。

约束与限制

本章节内容仅适用于MRS 3.5.0及之后版本。

配置积压告警规则

  1. 进入KafkaUI界面。

    1. 使用具有KafkaUI页面访问权限的用户登录FusionInsight Manager,选择“集群 > 服务 > Kafka”。

      如需在页面上进行相关操作,例如创建Topic,需同时授予用户相关权限,请参考Kafka用户权限说明

    2. 在“KafkaManager WebUI”右侧,单击URL链接,访问KafkaUI的页面。

  2. 在菜单栏单击“Alarms”,进入Kafka积压告警页面。
  3. 单击“Create Lag Alarm”,根据界面提示新建一条Kafka消息积压告警的规则,单击“Create”。

    图1 Create Lag Alarm
    表1 消息积压告警规则参数

    参数名称

    参数解释

    取值样例

    Consumer groups to be monitored

    需要监控的消费者组名称。

    example-group1

    Topics to be monitored

    需要监控的Topic名称。

    topic-1

    Lag threshold for major alarms

    发送重要告警时,消息积压的阈值。

    2

    Lag threshold for critical alarms

    发送紧急告警时,消息积压的阈值。

    4

    消息积压的计算规则为当前Topic中所有分区的消息积压(Lag)的总和,可以参考使用KafkaUI查看当前消费情况,查看消费者组中Topic所有分区的消息积压情况,如下图所示:

  4. 创建完成后,可以在“Lag Alarms”界面查看、修改、删除Kafka消息积压告警的规则信息。

相关文档

相关文档