准备好一个zk集群，比如 192.168.230.159:2181,192.168.230.162:2181,192.168.230.163:2181
准备三个服务器，分别为 192.168.230.186 192.168.230.187192.168.230.188
在每个服务器上面安装好jdk环境
在每个服务器上面安装好kafka单机，并测试通过
1 分别修改三个kafka的配置文件
server.properties ，分别修改以下属性：
broker.id 的值分别是 0,1,2
host.name 的值分别是各个机器的ip
advertised.host.name 的值分别是各个机器的ip
broker.list属性都设置为192.168.230.186:9092,192.168.230.187:9092,192.168.230.188:9092
producer.type属性都设置为异步async
然后保存每个文件并退出
2 先停止所有的kafka，如果服务器以前有kafka的日志文件，全部删除
3 在每个机器上分别启动kafka
/usr/kafka/bin/kafka-server-start.sh /usr/kafka/config/server.properties &
可以看到，每个机器都正确启动表示集群启动成功
4 测试集群
在三个打开的kafka集群窗口中都输入
生产者测试 ：输入
/usr/kafka/bin/kafka-console-producer.sh --broker-list 192.168.230.186:9092,192.168.230.187:9092,192.168.230.188:9092 --topic test
然后回车 可以进入生产者发消息模式
分别打开三个新的远程连接窗口，连接三个kafka集群服务器，然后在三个新窗口中输入
消费者测试：输入
/usr/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.230.186:9092,192.168.230.187:9092,192.168.230.188:9092 --topic test --from-beginning
然后回车 可以进入消费消息模式
在三个生产者测试窗口分别发消息出输入hello1，hello2，hello3
可以在三个消费消息窗口，看到分别都输出了三消息 hello1，hello2，hello3
kafka集群安装成功！
注意：zookeeper集群安装可以参考前面的仲裁模式教程
我们的交流基地，“JAVA互联网技术交流：789650498”欢迎小伙伴们一起来交流：
