全分布安装Kafka

　　1. 下载kafka安装包，访问Kafka官网下载对应版本即可。这里使用的版本为2.9.2-0.8.1.1。

　   2.  使用下面的命令解压安装包

1 tar -zxvf kafka_2.9.2-0.8.1.1.tgz

　　3. 修改配置文件，简单配置只需要修改/config/server.properties文件即可。

1 vim config /server .properties

　　需要修改的内容：

　　broker.id(标示当前server在集群中的id，从0开始)；port；host.name(当前的server host name)；advertised.host.name(当前的server host name);zookeeper.connect(连接的zookeeper集群)；log.dirs(log的存储目录，需要提前创建)。

　　示例：

　　4. 把配置好的kafka上传到其他节点上

1 scp -r kafka node2: /usr/

　　注意，上传之后不要忘了修改broker.id和host.nam等每个节点独有的配置。

四.启动并测试Kafka

　　1.首先启动Zookeeper（

bin/zookeeper-server-start.sh config/zookeeper.properties），之后使用一下命令启动Kafka，启动成功之后会有信息提示。

1 . /bin/kafka-server-start .sh config /server .properties &

　　2.对Kafka进行测试。分别创建topic，producer，consumer，最好是在不同的节点上创建。在producer的控制台上输入信息，观察consumer控制台是否能够接收到。

　　创建topic：

1 . /bin/kafka-topics .sh -zookeeper node1:2181,node2:2181,node3:2181 -topic test -replication-factor 2 -partitions 3 -create

　　查看topic：

1 . /bin/kafka-topics .sh -zookeeper node1:2181,node2:2181,node3:2181 -list

　　创建producer：

1 . /bin/kafka-console-producer .sh -broker-list node1:9092,node2:9092,node3:9092 -topic test

　　创建consumer：

1 . /bin/kafka-console-consumer .sh -zookeeper node1:2181,node2:2181,node3:2181 - from-begining -topic test

　　测试：

　　在producer的控制台输入信息，查看consumer的控制台能否接收到。

producer：

consumer

伪分布安装kafka

tar -xzf kafka_2.10-0.8.1.1.tgz 启动ZK bin/zookeeper-server-start.sh config/zookeeper.properties 启动服务 bin/kafka-server-start.sh config/server.properties 创建主题 bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 查看主题 bin/kafka-topics.sh --list --zookeeper localhost:2181

本文参考转载至：http://www.cnblogs.com/wxisme/p/5196302.html