1 安装JDK
1.1下载安装JDK和JRE
JDK（Java Development Kit）是Java客户管理系统开发定制语言的软件开发工具包，包括Java运行环境、Java开发工具、Java基础类库。
JRE（Java Runtime Environment）是Java运行环境，运行Java客户管理系统开发定制环境所必须的环境集合。
下载地址：
1.2 配置Java环境变量
“计算机”右键菜单--->属性--->高级系统设置--->环境变量--->系统变量-->新建..
JAVA_HOME指向JDK安装路径。
变量名：JAVA_HOME
变量值：C:\Program Files\Java\jdk1.8.0_60
CLASSPATH
变量名：CLASSPATH
变量值：.;%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\tools.jar;
找到Path变量，在变量值最后输入如下内容。
变量名：Path
变量值：%JAVA_HOME%\bin;%JAVA_HOME%\jre\bin;
1.3 验证Java环境变量配置是否成功
打开windows命令行窗口，输入java并回车。
打开windows命令行窗口，输入javac并回车。
2 安装Zookeeper
2.1 下载安装文件： http://zookeeper.apache.org/releases.html
2.2 解压文件到D:\Program Files\zookeeper-3.4.14
2.3 打开zookeeper-3.4.14\conf，把zoo_sample.cfg重命名成zoo.cfg
2.4 在文本编辑器里打开zoo.cfg
2.5 把dataDir的值改成如下：
dataDir=D:/Program Files/zookeeper-3.4.14/data
2.6 添加如下系统变量：
- 在系统变量中添加ZOOKEEPER_HOME 值为D:\Program Files\zookeeper-3.4.14
- 编辑Path：在现有的值后面添加 ;%ZOOKEEPER_HOME%\bin;
2.7 运行Zookeeper：打开cmd然后执行zkserver
注意，cmd窗口不要关闭。
3 安装Kafka
3.1 下载安装文件：
3.2 解压文件到D:\kafka_2.12-2.3.0
3.3 打开kafka_2.12-2.3.0\config
3.4 在文本编辑器里打开 server.properties
3.5 把 log.dirs的值改成如下：
log.dirs=D:/kafka_2.12-2.3.0/kafka-logs
3.6 打开cmd，进入kafka文件目录: cd D:\kafka_2.12-2.3.0
3.7 输入并执行：
.\bin\windows\kafka-server-start.bat .\config\server.properties
注意，cmd窗口不要关闭。
4 创建topic
4.1 打开cmd，进入cd D:\kafka_2.12-2.3.0\bin\windows
4.2 创建一个topic：
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
5 创建producer
5.1 打开cmd，进入cd D:\kafka_2.12-2.3.0\bin\windows
5.2 启动producer：
kafka-console-producer.bat --broker-list localhost:9092 --topic test
6 创建consumer
6.1 打开cmd，进入cd D:\kafka_2.12-2.3.0\bin\windows
6.2 启动consumer：
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
7 测试
在producer命令行中任意输入内容，回车；在其他consumer命令行中能看到相应消息。
8 其他命令
8.1 列出主题
kafka-topics.bat --list --zookeeper localhost:2181
8.2 描述主题
kafka-topics.bat --describe --zookeeper localhost:2181 --topic [Topic Name]
8.3 从头读取消息
kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic [Topic Name] --from-beginning
8.4 删除主题
kafka-run-class.bat kafka.admin.TopicCommand --delete --topic [topic_to_delete] --zookeeper localhost:2181
参考