参考网址：

前提条件：windows环境需要安装jdk

2.由于Kafka依赖于zookeeper，所以也需要下载zookeeper,可以通过官网下载http://zookeeper.apache.org/

3.安装zookeeper

将压缩包解压后，到bin目录下，启动zkServer.bat即可

注意：zookeeper的默认地址为：localhost:2181;需要配置环境变量：新建ZOOKEEPER_HOME,路径为zookeeper安装目录，将%ZOOKEEPER_HOME%\conf添加到path中

启动zookeeper成功

4.安装Kafka

解压kafka压缩包，其中Kafka配置文件config\server.properties中zookeeper的地址也默认为localhost:2181

选中kafka解压文件,shift+鼠标右键，选中“在此处打开命令行窗口(W)”，打开命令行，输入以下命令启动kafka：

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

启动完成后，再选中kafka解压文件,shift+鼠标右键，选中“在此处打开命令行窗口(W)”，打开命令行，输入以下命令，创建一个topic主题

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

使用如下命令查看创建的主题列表：bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

启动生产者,可以发送消息：

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

执行上面命令之后，可以在控制台随意输入文本

然后再选中kafka解压文件,shift+鼠标右键，选中“在此处打开命令行窗口(W)”，打开命令行，输入以下命令启动消费者

bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning

可以看到能够消费者成功接收消息