windows kafka 环境搭建踩坑记

版本介绍（64位）：

Windows 10

JDK1.8.0_171

zookeeper-3.4.8/

kafka_2.11-0.10.0.1.tgz

点击链接进行下载

1. JDK安装和环境搭建

　　自行百度。

2. zookeeper 安装和运行

a. 点击上方链接直接下载，或者有其他链接，下载此文件

b. 下载至本地，并解压

c. 更改配置文件

选择conf中的zoo_sample.cfg文件，改名为zoo.cfg,并更改配置文件内容.

改名为

更改配置文件内容，设置数据路径

d.  配置环境变量：

ZOOKEEPER_HOME：D:javazookeeper-3.4.8

Path: %ZOOKEEPER_HOME%in

d. 运行 zkServer

如果出现找不到命令的情况就使用管理员权限运行（因为我们没在用户环境变量里配置路径）

此窗口不要关闭 !!! ，新建cmd，检查Zookeeper有没有真正运行成功。

使用命令 netstat -ano，zookeeper默认端口为2181，找到2181标识，即为运行成功，zkserver窗口仍不要关闭，供之后调试kafka使用。

 2. kafka安装测试

a. 点击版本介绍处链接，直接下载，或者其他链接下载下方内容

b. 解压问题

使用解压工具解压后，出现无法打开的现象，并没有预期的文件夹，涉及到*.gz格式文件解压问题

使用7-Zip工具提取，具体参考： https://www.7-zip.org/，下载并直接安装便可

安装完成后，使用7-Zip提取.gz文件，【右击文件】--》【7-Zip】--》【打开压缩包】

 

 【双击打开】--》【提取】--》【选择提取位置】--》【确定】，提取出文件夹

c. 修改配置文件

log.dirs=D:\java\kafka_2.11-0.10.0.1\kafka-logs

zookeeper.connect=localhost:2181

 

d. 运行测试

1. 使用命令行工具，进入安装目录D:javakafka_2.11-0.10.0.1，执行以下命令

.inwindowskafka-server-start.bat .configserver.properties

kafka默认实例工作在9092端口，创建了broker 0，并注册入zookeeper

此窗口不要关闭!!!，作为 broker 服务

2. 创建主题

使用命令行工具，进入安装目录D:javakafka_2.11-0.10.0.1，执行以下命令,创建主题topic_test

.inwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_test

 查看主题：

.inwindowskafka-topics.bat --list --zookeeper localhost:2181

3. 创建生产者

使用命令行工具，进入安装目录D:javakafka_2.11-0.10.0.1，执行以下命令，不要关闭此窗口，进行信息生产

.inwindowskafka-console-producer.bat --broker-list localhost:9092 --topic topic_test

4. 创建消费者

使用命令行工具，进入安装目录D:javakafka_2.11-0.10.0.1，执行以下命令,不要关闭窗口，等待生产者的消息

.inwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topic_test --from-beginning --zookeeper 127.0.0.1:2181

5. 生产消息，并查看消费：

在生产者窗口输入消息：hello

 

在消费者窗口能够看到消息:hello

6. 在zookeeper中查看kafka的注册信息

命令行执行 zkcli，打开zookeeper客户端，可以执行操作命令

查看kafka brokers，结果如下

===========测试完毕===========