环境
硬件：小米笔记本 Air 13
处理器：i7
内存：8G
操作系统：Windows10 家庭中文版
系统补丁：截止2019-02-20的所有补丁
Java版本：1.8
zookeeper版本：3.4.12
kafka版本：2.12-2.1.1
安装
1. 搭建Java环境
2. 安装zookeeper
2.1 下载安装文件： 下载页面为http://zookeeper.apache.org/releases.html，选择版本为3.4.12
2.2 解压文件（本文解压到 C:\zookeeper\zookeeper-3.4.12）
2.3 打开C:\zookeeper\zookeeper-3.4.12\conf，把zoo_sample.cfg重命名成zoo.cfg
2.4 从文本编辑器里打开zoo.cfg
2.5 把dataDir的值改成C:/zookeeper/zookeeper-3.4.12/data
2.6
操作系统的环境变量中添加系统变量：ZOOKEEPER_HOME: C:\zookeeper\zookeeper-3.4.12
操作系统的用户变量修改Path，添加 %ZOOKEEPER_HOME%\bin;
2.7 运行Zookeeper: 打开cmd然后执行
zkserver
3. 安装并运行Kafka
3.1 下载安装文件： http://kafka.apache.org/downloads.html，选择版本为2.12-2.1.1
3.2 解压文件（本文解压到 C:\kafka\kafka_2.12-2.1.1）
3.3 打开C:\kafka\kafka_2.12-2.1.1\config
3.4 从文本编辑器里打开 server.properties
3.5 把 log.dirs的值改成 C:/kafka/kafka_2.12-2.1.1/kafka-logs
3.6 新增一行zookeeper.listeners=PLAINTEXT://localhost:9092
3.7 打开cmd进入kafka文件目录:
cd C:\kafka\kafka_2.12-2.1.1
3.8 输入并执行以打开kafka:
.\bin\windows\kafka-server-start.bat .\config\server.properties
如果出现报错命令语法不正确。
文本编辑器打开C:\kafka\kafka_2.12-2.1.1\bin\windows\kafka-run-class.bat文件，修改
set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp %CLASSPATH% %KAFKA_OPTS% %*
为
set COMMAND=%JAVA% %KAFKA_HEAP_OPTS% %KAFKA_JVM_PERFORMANCE_OPTS% %KAFKA_JMX_OPTS% %KAFKA_LOG4J_OPTS% -cp "%CLASSPATH%" %KAFKA_OPTS% %*
也就是把%CLASSPATH%改为"%CLASSPATH%"。
4. 创建一个topic
cd C:\kafka\kafka_2.12-2.1.1\bin\windows
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2
5. 打开一个Producer
cd C:\kafka\kafka_2.12-2.1.1\bin\windows
kafka-console-producer.bat --broker-list localhost:9092 --topic test2
6. 打开一个Consumer
cd C:\kafka\kafka_2.12-2.1.1\bin\windows
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test2 --from-beginning
至此，Kafka运行环境的搭建就完成了
参考
http://www.cnblogs.com/alvingofast/p/kafka_deployment_on_windows.html
https://blog.csdn.net/weixin_33446857/article/details/81982455
网友评论