一、下載地址：https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.2.0/kafka_2.11-0.10.2.0.tgz

Java: http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

Java的安裝http://czj4451.iteye.com/blog/2041159

二、啟動kafka自帶的zookeeper： ./bin/zookeeper-server-start.sh ./config/zookeeper.properties &

啟動Kafka：1）虛擬機啟動需要把這個環境變量設小，用默認的話會有問題export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"

2） ./bin/kafka-server-start.sh config/server.properties &

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

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

停止服務： ./bin/kafka-server-stop.sh ./bin/zookeeper-server-stop.sh

三、構造一個跨虛擬機的、只有一個kafka服務的環境

1）兩個在一個局域網的Ubuntu虛擬機(一個叫master,一個叫slaver1)

2）一個虛擬機(master)上面起zookeeper、kafka服務、kafka-producer；

要修改下config/server.properties中的listeners（效果同之前的版本的host.name及port：註意綁定host.name，否則可能出現莫名其妙的錯誤如consumer找不到broker。這個host.name是Kafka的server的機器名字，會註冊到Zookeeper中)

虛擬機ip是10.0.0.5，不改的話，listeners默認取值localhost

producer代碼是

3)另一個虛擬機(slaver1)上起kafka-consumer

代碼是

kafka實戰