使用windows的kafka时,需要集成Zookeeper,可以直接使用带Zookeeper的kafka,也可以单独安装Zookeeper,我这里把两种方法都记录一下。
确保windows机器有java环境。
单独安装Zookeeper
一、安装Zookeeper
①下载Zookeeper:https://zookeeper.apache.org/releases.html
②解压进入Zookeeper目录并创建data目录
③进入conf目录,将zoo_sample.cfg重命名为zoo.cfg
④打开zoo.cfg修改dataDir=data
⑤在系统环境变量中添加变量:ZOOKEEPER_HOME=C:softwarezookeeperapache-zookeeper-3.6.3-bin(这里指的是自己的Zookeeper解压的路径)
⑥编辑path系统变量,添加路径:%ZOOKEEPER_HOME%bin
⑦打开cmd,输入“zkServer”,运行Zookeeper
⑧如下表示成功启动(不要关闭窗口):
二、安装kafka
①下载安装包:http://kafka.apache.org/downloads
②解压安装包
③进入config目录编辑server.properties
④编辑log.dirs=logs
⑤进入解压目录,binwindows目录,输入:kafka-server-start.bat ....configserver.properties
⑥启动成功如下图(注意不要关闭窗口):
三、测试
①创建主题,进入解压目录,进入binwindows目录,输入:
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-topic
②查看主题,进入解压目录,进入binwindows目录,输入:
kafka-topics.bat --list --zookeeper localhost:2181
安装带Zookeeper的kafka:
上一步中的安装kafka的安装包里面,已经自带Zookeeper,只需要运行Zookeeper就行
一、运行Zookeeper
①进入kafka解压目录
②进入config目录,修改Zookeeper.properties,将dataDir=xxxx修改为自己设置的data目录
③进入binwindows目录,输入:
zookeeper-server-start.bat ....configzookeeper.properties
④Zookeeper正常启动,不要关闭窗口
二、运行kafka
如上单独安装Zookeeper操作一样
三、测试
如上测试一样
需要注意一点,如果之前kafka经连接过单独的或者自带的Zookeeper,再换一种方式验证启动kafka时,需要先将logs数据删除,否则会出现认证id不匹配的报错。



