注意 kafka包路径不要太长,不然启动时候

这里再单独下个zookeeper做为三个kafka实例broker的注册中心

修改Zookeeper配置文件

脚本内容

call bin/zkServer.cmd    不然的话就进bin目录双击zkServer.cmd

配置Zookeeper的另外一种方式

用Kafka自带的zookeeper

例如我复制一份 kafka_broker_2

改名为kafka-zk

修改下kafka-zk/config下的zookeeper.properties

配置对应脚本

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

配置各个kafka Broker

然后在每个kafka-broker里创建kafka.cmd文件

并编辑保存

call bin\windows\kafka-server-start.bat config\server.properties

启动顺序就是先启动zookeeper   再启动每个kafka

也可以在外部在配置一个cluster.cmd

一次来启动   脚本

cd kafka-zk
start zk.cmd
ping 127.0.0.1 -n 10 >nul
cd ../kafka_broker_1
start kafka.cmd
cd ../kafka_broker_2
start kafka.cmd
cd ../kafka_broker_3
start kafka.cmd

再创建一个清理的脚本  生产中不要这么用

创建cluster-clear.cmd

脚本

cd kafka-zk
rd /s /q data
cd ../kafka_broker_1
rd /s /q data
cd ../kafka_broker_2
rd /s /q data
cd ../kafka_broker_3
rd /s /q data

这样 也可以把独立的zookeeper配置进去