在windows安装并启动测试kafka教程
在windows安装并启动测试kafka
https://www.jianshu.com/p/ce203d4e2f41 从这个文章中学习
安装
http://kafka.apache.org/downloads 直接下载。根据所用的系统。
windows的直接在本地解压缩即可。
准备工作：
1、java环境
2、kafka安装包，（已包含zookeeper）
启动测试
我本地的windows的kafka的安装目录在 D:\kafka_2.12-2.8.0
第一步： 新开窗口，启动zookeeper
D:\kafka_2.12-2.8.0\bin\windows>zookeeper-server-start.bat ..\..\config\zookeeper.properties
第二步： 新开窗口，启动kafka
D:\kafka_2.12-2.8.0\bin\windows>kafka-server-start.bat ..\..\config\server.properties
第三步： 新开窗口，测试Kafka命令
1、创建一个主题， 窗口不要关
D:\kafka_2.12-2.8.0\bin\windows>kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test-topic
2、查看创建的主题列表
D:\kafka_2.12-2.8.0\bin\windows>kafka-topics.bat --list --zookeeper localhost:2181
========================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================================
上述两个步骤执行
![image-20210623091939618]()
第四步： 新开窗口，启动生产者
D:\kafka_2.12-2.8.0\bin\windows>kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic
第五步： 新开窗口，启动消费者
D:\kafka_2.12-2.8.0\bin\windows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning
![image-20210623094611300]()