标签：
kafka是一种高吞吐量的分布式发布订阅消息系统，她有如下特性：
Kafka的目的是提供一个发布订阅解决方案，它可以处理消费者规模的网站中的所有动作流数据。
这种动作（网页浏览，搜索和其他用户的行动）是在现代网络上的许多社会功能的一个关键因素。
这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。
对于像Hadoop的一样的日志数据和离线分析系统，但又要求实时处理的限制，这是一个可行的解决方案。kafka的目的是通过Hadoop的并行加载机
制来统一线上和离线的消息处理，也是为了通过集群机来提供实时的消费。
下图为kafka的架构图：
1、下载Kafka bin包
下载地址：https://www.apache.org/dyn/closer.cgi?path=/kafka/0.8.0/kafka_2.8.0-0.8.0.tar.gz
这里可能有很多童鞋执行sbt的时候会报找不到这个命令
这个是需要自己安装的，安装包可以到sbt官网下载。我这边用的ubuntu系统，所以我下载了个deb包，官网地址：http://www.scala-sbt.org/
deb包地址：http://repo.scala-sbt.org/scalasbt/sbt-native-packages/org/scala-sbt/sbt/0.13.1/sbt.deb
rpm包地址：http://repo.scala-sbt.org/scalasbt/sbt-native-packages/org/scala-sbt/sbt/0.13.1/sbt.rpm
2、启动服务
官网教程中有启动zookeeper这一项，启动zookeeper之前要配置好zookeeper.properties
由于我这边使用的是独立的zookeeper，所以无需执行以上步骤；
如果想知道zookeeper独立安装步骤，可以查看我的博客http://blog.csdn.net/weijonathan/article/details/8591117
有了zookeeper之后我们启动Kafka服务，但是在这之前我们要先配置好kafka的server.properties文件
将server.properties中的zookeeper.connect配置为你的zookeeper集群地址
接下来启动kafka
3、创建Topic
创建一个名为“test”只有一个分区，只有一个副本的Topic：
运行list topic命令，可以看到Topic列表
4、发送消息
kafka自带的一个命令行客户端，运行后可以输入消息，kafka会将其发送到kafka进群进行消息消费。默认情况下，每一行数据被作为一个消息进行发送。
接下来我们运行producer试试
这里输入This is a message和This is another message
5、启动消费者(consumer)
上面我们通过kafka自带的命令行输入了两行消息，那么我们现在启动消费者看看是否会接收到。
可以看到消费者已经对我们上面输入的数据进行处理了；
标签：
原文地址：http://www.cnblogs.com/yepei/p/4764042.html
