小米流式平台的愿景是为小米所有的业务线提供流式数据的一体化、平台化解决方案。具体来讲包括以下三个方面:流式数据存储:流式数据存储指的是消息队列,小米开发了一套自己的消息队列,其类似于Apachekafka,但它有自己的特点,小米流式平台提供消息队列的存储功能;流式数据接入和转储:有了消息队列来做流式数据的缓存区之后,继而需要提供流式数据接入和转储的功能;流式数据处理:指的是平台基于Flink、SparkStreaming和Storm等计算引擎对流式数据进行处理的过程。下图展示了流式平台的整体架构