kafka在windows环境下集群部署

下载 kafka 安装包

下载地址：Kafka

下载后在 E 盘下新建文件夹 kafka-cluster ，将下载的压缩包解压到 kafka-cluster 目录下并复制 4 份，分别改名为，kafka-zk，kafka1，kafka2，kafka3。

kafka-zk： 统一 kafka 节点的 zookeeper ，因为 kafka 内置了 ZooKeeper 软件，所以此处将解压缩的文件作为 ZooKeeper 软件使用。
kafka1： 表示第一个节点。
kafka2： 表示第二个节点。
kafka3： 表示第三个节点。

修改 kafka-zk/config/zookeeper.properties 文件下的内容

1	dataDir=E:/kafka-cluster/kafka-zk/data

修改 kafka1/config/server.properties 文件下的内容

1
2
3

broker.id=1
listeners=PLAINTEXT://:9091
log.dirs=E:/kafka-cluster/kafka1/data

修改 kafka2/config/server.properties 文件下的内容

1
2
3

broker.id=2
listeners=PLAINTEXT://:9092
log.dirs=E:/kafka-cluster/kafka2/data

修改 kafka3/config/server.properties 文件下的内容

1
2
3

broker.id=3
listeners=PLAINTEXT://:9093
log.dirs=E:/kafka-cluster/kafka3/data

（1）封装 zookeeper 启动脚本

在 kafka-zk 文件夹下新建 zk.cmd 文件

1	call bin/windows/zookeeper-server-start.bat config/zookeeper.properties

（2）封装 kafka 启动脚本

在 kafka1，kafka2，kafka3 新建 kafka.cmd 文件

1	call bin/windows/kafka-server-start.bat config/server.properties

（3）封装集群启动脚本

在 kafka-cluster 目录下新建 cluster.cmd 文件

cd kafka-zk
start zk.cmd
ping 127.0.0.1 -n 10 >nul
cd ../kafka1
start kafka.cmd
cd ../kafka2
start kafka.cmd
cd ../kafka3
start kafka.cmd

在 kafka-cluster 目录下新建 cluster-clear.cmd 文件用于清除 kafka 运行产生的数据

cd kafka-zk
rd /s /q data
cd ../kafka1
rd /s /q data
cd ../kafka2
rd /s /q data
cd ../kafka3
rd /s /q data

启动 cluster.cmd 脚本就可以启动集群服务了。