一、下载地址：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
代码是
原文：http://www.cnblogs.com/testzcy/p/7514451.html