storm与spark streaming反压机制

因特殊业务场景,如大促、秒杀活动与突发热点事情等业务流量在短期内剧增,造成巨大的流量毛刺,数据流入的速度远高于数据处理的速度,对流处理系统构成巨大的负载压力,若是不能正确处理,可能致使集群资源耗尽最终集群崩溃,所以有效的反压机制(backpressure)对保障流处理系统的稳定相当重要。html Storm和Spark Streaming都提供了反压机制,实现各不相同 git 对于开启了acker
相关文章
相关标签/搜索