windows平台下kafka简单安装使用

windows平台下kafka简单安装使用

一、安装jdk

二、安装zookeeper

Kafka的运行依赖于Zookeeper，所以在运行Kafka之前我们需要安装并运行Zookeeper

1、下载zookeeper并修改参考上一篇：https://blog.csdn.net/qq_32595131/article/details/103297223

2、配置环境变量

1)ZOOKEEPER_HOME:D:\machine\kafka_2.11-1.1.0
2)Path: 在现有的值后面添加";%ZOOKEEPER_HOME%\bin;"

3、启动zookeeper：

打开cmd然后执行zkserver

三、安装kafka

1、下载kafka：

https://www.apache.org/dyn/closer.cgi?path=/kafka/1.1.0/kafka_2.11-1.1.0.tgz

2、解压文件到D:\machine\kafka_2.11-1.1.0

3、在D:\machine\kafka_2.11-1.1.0下新建文件名为kafka-logs，打开D:\machine\kafka_2.11-1.1.0\config，修改log.dirs=D:\machine\kafka_2.11-1.1.0\kafka-logs

4、cmd中进入kafka目录，D:\machine\kafka_2.11-1.1.0，执行以下命令，启动kafka通讯的服务器broker：

.\bin\windows\kafka-server-start.bat .\config\server.properties
启动过程报错，参考此链接：https://blog.csdn.net/weixin_44100514/article/details/88413870 可解决

5、重新打开一个cmd，进入kafka文件目录D:\machine\kafka_2.11-1.1.0\bin\windows，创建kafka的消息topics

6、分别打开两个cmd窗口，进入目录D:\machine\kafka_2.11-1.1.0\bin\windows，创建Producer和Consumer

（1）Producer
进入目录D:\machine\kafka_2.11-1.1.0\bin\windows输入如下命令：
kafka-console-producer.bat --broker-list localhost:9092 --topic testDemo

（2）Consumer
进入目录D:\machine\kafka_2.11-1.1.0\bin\windows输入如下命令：
kafka-console-consumer.bat --zookeeper localhost:2181 --topic testDemo

然后就可以在Producer中发信息，在Consumer中收信息了

7、未完 java代码测试

参考链接： 1、https://www.cnblogs.com/mh-study/p/9537970.html 2、https://blog.csdn.net/tiantangdizhibuxiang/article/details/80556064