kafka是需要zk来支持.所以先下载zk
1.下载安装zookeeper
下载地址
选择不带source的
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623140133932.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623140319437.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
下载下来解压2次
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623140616582.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
进入到 D:\zookeeper\apache-zookeeper-3.6.1-bin\conf 目录下,把zoo_sample.cfg重命名成zoo.cfg
修改zoo.cfg
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623141305164.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
会在这里生成数据文件
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623141333239.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
添加ZK环境变量
![在这里插入图片描述](https://img-blog.csdnimg.cn/2020062314150938.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623141542567.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
ZK到此配置完成.可以启动ZK了
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623141638572.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
或者打开cmd 输入zkserver
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623141810791.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
提示这个启动成功!
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623141841487.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
2.下载安装kafka
下载地址
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623113430696.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
下载最新版本
![在这里插入图片描述](https://img-blog.csdnimg.cn/2020062311355979.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
下载下来之后解压,得解压2次
![在这里插入图片描述](https://img-blog.csdnimg.cn/2020062311395678.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
进入到:D:\kafka\kafka_2.12-2.5.0\config
修改 server.properties
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623114141254.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
进入到 D:\kafka\kafka_2.12-2.5.0目录执行.\bin\windows\kafka-server-start.bat .\config\server.properties
![在这里插入图片描述](https://img-blog.csdnimg.cn/2020062311433790.png)
kafka启动成功!
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623114429953.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
测试使用
zk和刚启动的kafka不要关闭
创建topic
进入到kafka的windows目录中执行以下命令,2181是zookeeper端口
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623143836626.png)
创建topic成功!
再启动两个窗口,一个消费者,一个生产者
还进进入到kafka的windows目录下执行以下命令.9092是kafka的端口
生产者:kafka-console-producer.bat --broker-list localhost:9092 --topic demo
消费者:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginning
![在这里插入图片描述](https://img-blog.csdnimg.cn/2020062314430818.png)
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623144330725.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
启动的4个服务:
![在这里插入图片描述](https://img-blog.csdnimg.cn/20200623144736679.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RheW9uZ2xvdmUyMDE4,size_16,color_FFFFFF,t_70)
可以在生产者服务的窗口随意输入内容,消费者服务的窗口都会接收到.到此测试完成,测试结果OK!
欢迎大佬们留言评论,共同学习!!!感谢!!!
===========================
原创文章,转载注明出处!