已经在考虑且已经试验，使用kafka的一个原因就是因为storm、spark streaming等可以非常方便地接入进行运算，通过mophling可以很容易对流式框架数据处理过程进行监控。`