Apache Kafka 是一个分布式流媒体平台 流媒体平台有三个关键功能: 1.发布和订阅记录流，类似于消息队列或企业消息传递系统。 2.以容错的持久方式存储记录流。 3.记录发生时处理流。 Kafka通常用于两大类应用: 构建可在系统或应用程序之间可靠获取数据的实时流数据管道 构建转换或响应数据流的实时流应用程序
kafka是什么?
在流计算中，kafka主要功能是用来缓存数据，storm可以通过消费kafka中的数据进行流计算。 是一套开源的消息系统，由scala写成。支持javaAPI的。 kafka最初由LinkedIn公司开发，2011年开源。 2012年从Apache毕业。 是一个分布式消息队列，kafka读消息保存采用Topic进行归类。
角色
发送消息:Producer(生产者) 接收消息:Consumer(消费者)
为什么要用消息队列
1)解耦 为了避免出现问题 2)拓展性 可增加处理过程 3)灵活 面对访问量剧增，不会因为超负荷请求而完全瘫痪。 4)可恢复 一部分组件失效，不会影响整个系统。可以进行恢复。 5)缓冲 控制数据流经过系统的速度。 6)顺序保证 对消息进行有序处理。 7)异步通信 akka,消息队列提供了异步处理的机制。允许用户把消息放到队列 ， 不立刻处理。
kafka架构设计
kafka依赖zookeeper，用zk保存元数据信息。 搭建kafka集群要先搭建zookeeper集群。
zk在kafka中的作用?
保存kafka集群节点状态信息和消费者当前消费信息。
