1、从Kafka的官网下载Kafka安装包:Apache Kafka
2、下载后解压
3、因为是在windows下安装,需要修改路径,解压后的config目录下(kafka_2.13-3.5.0\config),
①zookeeper.properties中修改zookeeper的路径:dataDir=E:/Java_SZ/Kafka/zookeeper
②server.properties中修改kafka的路径:log.dirs=E:/Java_SZ/Kafka/kafka-logs
PS:Windows下使用Kafka出现一些问题,定时删除kafka-logs目录下的文件即可。
4、启动测试:
①先启动zookeeper:E:\Java_SZ\Kafka\kafka_2.13-3.5.0 > bin\windows\zookeeper-server-start.bat config\zookeeper.properties
②再启动kafka:E:\Java_SZ\Kafka\kafka_2.13-3.5.0>bin\windows\kafka-server-start.bat config\server.properties
5、使用测试:
①在启动一个命令窗口创建主题:\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
②启动生产者:\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
③启动消费者:\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
版权归原作者 笔芯啵啵 所有, 如有侵权,请联系我们删除。