kafka概述

从官网的介绍来看，Kafka是一个分布式的消息订阅系统，它主要有3种功能：
　　1、It lets you publish and subscribe to streams of records.发布和订阅消息流，这个功能类似于消息队列，这也是kafka归类为消息队列框架的原因。
　　2、It lets you store streams of records in a fault-tolerant way.以容错的方式记录消息流，kafka以文件的方式来存储消息流。
　　3、It lets you process streams of records as they occur.可以再消息发布的时候进行处理。

kafka架构图

kafka架构图.png

kafka应用

目前kafka被广泛应用于互联网企业，在大数据领域主要用于作为实时数据处理中间件，在微服务应用中多作为消息队列中间件使用。kafka的应用场景大致可以概括为如下两个方面：
1、Building real-time streaming data pipelines that reliably get data between systems or applications.在系统或应用程序之间构建可靠的用于传输实时数据的管道，消息队列功能。
2、Building real-time streaming applications that transform or react to the streams of data。构建实时的流数据处理程序来变换或处理数据流，数据处理功能。

kafka优势

大致有以下几个有点，
1、解耦。脱离应用本身，只是作为消息存储的中间件，不涉及业务逻辑于处理逻辑。
2、拓展性。kafka消息传递系统轻松缩放，无需停机。
3、灵活。面对访问量剧增，不会因为超负荷请求而完全瘫痪。
4、可恢复。分布式的，分区，复制和容错的。一部分组件失效，不会影响整个系统，可以进行恢复。
5、缓冲。控制数据流经过系统的速度。
6、顺序保证。对消息进行有序处理。
7、异步通信。 akka,消息队列提供了异步处理的机制。允许用户把消息放到队列 ， 不立刻处理。
8、耐用性：kafka使用分布式提交日志，这意味着消息会尽可能快速的保存在磁盘上，因此它是持久的。
9、性能：kafka对于发布和定于消息都有高吞吐量。即使存储了许多TB的消息，他也爆出稳定的性能。