日志实时分析架构

在上家公司工作时，设计的日志收集与实时分析架构，还是比较简单的: flume-ng + rocketmq + storm + redis + 前端展示 消息队列部分，我们刚开始采用的是kafka，但 kafka在支持回溯消费和重复消费方面比较弱，同时在数据安全方面也相对弱一些，后来我们改为阿里的rocketmq。 考虑到我们的数据量也不是很大，已经能够足够支撑，但在rocketmq这层，有时会因为

>>阅读原文<<