kafka-13-windows中安装kafka

参考windows下安装kafka教程

1 windows安装java

解压目录D:\Java\jdk1.8.0_201

2 windows安装zookeeper

zookeeper官网地址

2.1 解压安装使用

一、下载
下载zookeeper，选择自己需要的版本，并解压。
从目前的最新版本3.5.5开始，带有bin名称的包才是我们想要的下载可以直接使用的里面有编译后的二进制的包，而之前的普通的tar.gz的包里面是只是源码的包无法直接使用。
apache-zookeeper-3.7.0-bin.tar.gz
二、解压
可以看到我们下载的是.tar.gz后缀的文件，这种一般是放在Linux上安装，现在我们在Windows安装，如果我们用正常的方式来解压时可能会出现 “压缩文件损坏等错误”。

解决方法：
在我们安装包的文件夹位置，按 Shift ，鼠标右键，使用 Powershell 来进行解压。

CMD> tar -xzvf .\apache-zookeeper-3.7.0-bin.tar.gz
解压完成后拷贝到下面的目录中
D:\soft\zookeeper\apache-zookeeper-3.7.0-bin

三、创建文件夹data和log

四、修改配置文件zoo.cfg
进入conf文件夹，复制zoo_sample.cfg文件并重命名为zoo.cfg。
更改zoo.cfg配置，创建的文件夹data和log的路径。
这里配置的路径使用双斜杠，如果是单斜杠，在我们启动服务端的时候就会把我们配置的内容输出到bin目录下面。

dataDir=D:\\soft\\zookeeper\\apache-zookeeper-3.7.0-bin\\data 
dataLogDir=D:\\soft\\zookeeper\\apache-zookeeper-3.7.0-bin\\log

五、双击bin目录下的zkServer.cmd启动

六、双击bin目录下的zkCli.cmd连接测试

2.2 问题zkServer.cmd双击闪退

有的时候会出现双击闪退的情况。
针对闪退，可按照一下步骤进行解决：

1、编辑zkServer.cmd文件末尾添加pause。
这样运行出错就不会退出，会提示错误信息，方便找到原因。

例如原因如下：

2、修改bin\zkEnv.cmd文件 ，配置JAVA_HOME

set JAVA_HOME="D:\Java\jdk1.8.0_201" 

3 windows安装kafka

kafka官网地址

3.1 解压安装使用

一、下载
注意下载binary版本

二、解压
可以看到我们下载的是.tar.gz后缀的文件，这种一般是放在Linux上安装，现在我们在Windows安装，如果我们用正常的方式来解压时可能会出现 “压缩文件损坏等错误”。

解决方法：
在我们安装包的文件夹位置，按 Shift ，鼠标右键，使用 Powershell 来进行解压。

CMD> tar -xzvf .\kafka_2.13-3.1.0.tgz
解压完成后拷贝到下面的目录中
D:\soft\kafka\kafka_2.13-3.1.0

三、修改配置文件server.properties
进入config目录下，找到server.properties文件，并作以下修改：
1、找到并编辑 log.dirs=D:\soft\kafka\kafka_2.13-3.1.0\kafka-logs
(kafka的解压目录，kafka-logs文件夹不用自己新建)
2、找到并编辑zookeeper.connect=localhost:2181
(一般默认就是localhost:2181)

四、启动kafka
win+R 输入cmd，打开命令窗口，进入安装目录D:\soft\kafka\kafka_2.13-2.8.0，输入以下命令 ( 成功之后不要关闭窗口)

CMD>.\bin\windows\kafka-server-start.bat .\config\server.properties

3.2 测试

(1)创建主题，打开一个新的命令窗口，进入安装目录
D:\soft\kafka\kafka_2.13-2.8.0，输入以下命令
成功之后不要关闭窗口
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

(2)查看主题
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

(3)创建生产者，打开一个新的命令窗口，进入安装目录
D:\soft\kafka\kafka_2.13-2.8.0，输入以下命令
成功之后不要关闭窗口
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

(4)创建消费者，打开一个新的命令窗口，进入安装目录
D:\soft\kafka\kafka_2.13-2.8.0，输入以下命令
成功之后不要关闭窗口
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning