1. 安裝Java
java安裝詳見：http://www.itdecent.cn/p/5d3ecf3b30f6
2. 安裝zookeeper
在需要安裝的目錄下運(yùn)行： wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.9/zookeeper-3.4.9.tar.gz （這個(gè)地址根據(jù)官方推薦的，可能會(huì)有不同）。
解壓包：tar -xzf zookeeper-3.4.9.tar.gz。
進(jìn)入解壓的文件夾：cp /config/zoo-sample.cfg /config/zoo.cfg。
運(yùn)行zookeeper：/bin/zkServer.sh start。
3. 安裝kafka
在需要安裝的目錄下運(yùn)行： wget http://mirror.bit.edu.cn/apache/kafka/0.11.0.0/kafka_2.12-0.11.0.0.tgz（這個(gè)地址根據(jù)官方推薦的，可能會(huì)有不同）。
解壓包：tar -xzf kafka_2.12-0.11.0.0.tgz。
進(jìn)入解壓文件夾的bin目錄，運(yùn)行：./kafka-server-start.sh ../config/server.properties。
ps -ef | grep kafka查看zookeeper和kafka服務(wù)是否啟動(dòng)。
4. 測試
1.創(chuàng)建一個(gè)叫"test"的topic，它只有一個(gè)分區(qū)，一個(gè)副本：./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2.查看創(chuàng)建的topic：./kafka-topics.sh --list --zookeeper localhost:2181
3.創(chuàng)建producer：./kafka-console-producer.sh --broker-list localhost:9092 --topic test
4.創(chuàng)建consumer：./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
5.在producer控制臺(tái)輸入信息敲回車，可以在consumer控制臺(tái)看到對應(yīng)的信息
6. kafka所在服務(wù)器跟開發(fā)環(huán)境不在一臺(tái)機(jī)器上：
把listeners和advertised.listeners前面的＃去掉，并把端口號(hào)之前的一串英文改為服務(wù)器的ip地址如：
listeners=PLAINTEXT://192.168.1.195:9092
advertised.listeners=PLAINTEXT://192.168.1.195:9092
zookeeper.connect=localhost:2181改為zookeeper.connect=192.168.1.195:2181
