如下有3台虚拟机，对应的IP如下：

下一台

下一台

对应的3给IP地址如下：

192.168.94.129

192.168.94.131

192.168.94.132

 

 

这里默认jdk 1.8是安装好了的。

 

 

首先是安装zookeeper，分布式部署，随后再部署kafka

解压后进入zookeeper，的conf。拷贝一份zoo_sample.cfg为zoo.cfg

修改zoo.cfg

上面3台服务器都是需要这样配置。并且再/tmp/zookeeper创建一个myid文件，写入server.x中的x，这个x。如192.168.94.129中myid为0，192.168.94.131中myid为1

在bin目录里面启动

./zkServer.sh start

这里会在conf下自动去找zoo.cfg文件

如果有问题会出现到

zookeep.out文件夹中记录出现的错误，有问题就查看这个文件。启动成功后。

 

上面每一台都要这么做。

 

输入./zkServer.sh status查看状态：

下面是搭建集群kafka

解压kafka后修改config下面的server.properties

添加如下数据：

broker.id=0
listeners=PLAINTEXT://192.168.94.129:9092
zookeeper.connect=192.168.94.129:2181,192.168.94.131:2181,192.168.94.132:2181

这个broker.id=0为/tmp/zookeeper/myid的id。

 

再修改

meta.properties文件如下

把broker.id添加当前myid的值。

 

随后就可以启动kafka了。集群就搭建好了

在bin目录下./kafka-server-start.sh ../config/server.properties

这里报错信息会打印到前端，有问题要即使处理。

 

添加一个topic

./kafka-topics.sh --create --zookeeper 192.168.94.129:2181,192.168.94.131:2181,192.168.94.132:2181 --partitions 3 --replication-factor 3 --topic HelloWorld

往topic里面添加消息

./kafka-console-producer.sh --broker-list 192.168.94.129:9092,192.168.94.131:9092,192.168.94.132:9092 --topic HelloWorld

就可以发送消息了：

随便找某一台进行消费

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic HelloWorld --from-beginning