参考网址：

 

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

1.下载Kafka,可以通过官网下载Kafka，，目前使用版本  (, )

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

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

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