我们使用官网比较新的2.11_1.0.0版本安装。
1.官网上下载安装包
http://kafka.apache.org/downloads
接下来解压jar包：
tar -zxvf kafka_2.11-1.0.0.tgz
2.修改zookeeper.properties配置文件
initLimit=10
syncLimit=5
server.1=192.168.1.101:2888:3888
server.2=192.168.1.102:2888:3888
server.3=192.168.1.102:2888:3888
3.修改server.properties配置文件
broker.id=0
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://外网IP地址:9092
advertised.host.name=192.168.1.101
zookeeper.connect=192.168.1.101:2181,192.168.1.102:2181,192.168.1.103:2181
default.replication.factor=2
num.partitions=5
log.dirs=/mnt/data/kafka-logs
4.测试集群
生产者窗口：
./kafka-console-producer.sh –broker-list 192.168.1.101:9092,192.168.1.102:9092,192.168.1.103:9092 –topic test
消费者窗口：
./kafka-console-consumer.sh –zookeeper 192.168.1.101:2181,192.168.1.102:2181,192.168.1.103:2181 –topic test –from-beginning