Windows OS上搭建Kafka

准备材料

1. jdk
2. zookeeper安装包（https://zookeeper.apache.org/releases.html）
3. kafka安装包（http://kafka.apache.org/downloads），下载Binary downloads中的

安装前注意，zookeeper以及kafka的目录，路径中最好不要出现空格

Zookeeper安装

• 进入安装路径C:\ProgramData\zookeeper-3.4.14\conf中将"zoo_sample.cfg"重命名为"zoo.cfg"
• 将zoo.cfg中的dataDir属性改为自己的安装目录 C:\\ProgramData\\zookeeper-3.4.14\\data
• 添加环境变量ZOOKEEPER_HOME=C:\ProgramData\zookeeper-3.4.14，Path中添加%ZOOKEEPER_HOME%\bin
• 打开cmd窗口，输入zkserver，结果如下，表示成功

           

Kafka安装

• 进入C:\ProgramData\kafka_2.11-2.3.0\config路径，修改server.properties中log.dirs属性为安装路径C:\\ProgramData\\kafka_2.11-2.3.0\\kafka-logs
• 进入目录C:\ProgramData\kafka_2.11-2.3.0，输入.\bin\windows\kafka-server-start.bat .\config\server.properties，结果如下

            

验证安装是否成功

• 新开窗口，进入目录C:\ProgramData\kafka_2.11-2.3.0\bin\windows
• 创建主题mytest，命令kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytest

           

• 新开窗口，同样的目录
• 创建生产者，kafka-console-producer.bat --broker-list localhost:9092 --topic mytest
• 新开窗口，同样的目录
• 创建消费者，kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic mytest --from-beginning

最终结果如下：

但中文会有乱码的情况，还待解决