实时告警架构优化实战

简介 线上有一个告警服务采用sparkstreaming+kafka的模式实时处理数据进行布控告警，10s一个批次，34个executor，每个4core，kafka有260个分区，采用直读的方式并且打开了慢执行推测。 运行一段时间后，都没有延迟，目前布控任务有1000个左右，每天4000万的数据需要处理，昨晚业务突然添加了2000个布控任务，导致任务有积压，导致告警延迟两个多小时，经过排查，发现

>>阅读原文<<