linux安装kafka

一、下载KAFKA安装包

Apache官网 http://kafka.apache.org/downloads.html

---

二、上传并且解压KAFKA安装包

tar -xzf kafka_2.10-0.8.2.2.tgz

cd kafka_2.10-0.8.2.2

---

三、启动服务

KAFKA需要启动两个服务：

1，启动zookeeper：bin/zookeeper-server-start.sh config/zookeeper.properties & (&能在执行指令时退出操作)

2，启动kafka：bin/kafka-server-start.sh config/server.properties &

---

四、测试

1，创建topic

bin/kafka-topics.sh --create --zookeeper 10.202.4.179:2181 --replication-factor 1 --partitions 1 --topic test

创建一个名为test的topic，只有一个副本，一个分区。

2，创建生产者，启动producer

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

topic要对应之前创建的topic

之后便可以发送消息

3，创建消费者，启动consumer

bin/kafka-console-consumer.sh --zookeeper 10.202.4.179:2181 --topic test --from-beginning

topic要对应之前创建的topic

在生产者发送消息后，消费者便可以收到对应的消息了

---

五、server.properties，zookeeper.properties配置介绍

http://blog.csdn.net/suifeng3051/article/details/48053965