java查看kafka集群状态_kafka 集群--3个broker 3个zookeeper

时间:2024-10-11 20:05:32

准备工作:

1. 准备3台机器,IP地址分别为:192.168.0.10,192.168.0.11,192.168.0.12

2. 下载kafka稳定版本,我的版本为:kafka_2.9.2-0.8.1.

3. 分别解压放入到想安装的目录下,我的目录为:/home/www 解压命令为:

tar -xzf kafka_2.9.2-0.8.1.

搭建zookeeper集群

1. 进入解压后的目录/home/www/kafka_2.9.2-0.8.1.1

2. 进入config目录下,修改文件

tickTime=2000dataDir=/data/zookeeper/clientPort=2181initLimit=5syncLimit=2server.1=192.168.0.10:2888:3888server.2=192.168.0.11:2888:3888server.3=192.168.0.12:2888:3888

在dataDir目录/data/zookeeper/下写一个myid文件,命令如下:

echo 1 >myid

注意:这个id是zookeeper的主机标示,每个主机id不同第二台是2 第三台是3。

逐次启动3台机器的zookeeper 构成一个集群:

> bin/ config/ &

注意:使用& 会打印出启动日志,但如果使用secure

ssh