二、下载Kafka安装包
三、解压文件
四、打开\conf文件夹,找到server.properties文件,把log.dirs的值改成“./logs”
五、到Kafka的文件夹下,按shit键+鼠标右键打开cmd命令行。
六、.\bin\windows\kafka-server-start.bat .\config\server.properties
注意:文件夹的路径不要太长,不然会提示“输入行太长,命令语法不正确”
执行结果以下图所示:
测试:
一、建立topic,打开新cmd窗口
.\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
二、打开新
cmd窗口(生产者)
cd D:\Project\分布式\kafka_2.13-2.4.0\bin\windows> .\kafka-console-producer.bat --broker-list localhost:9092 --topic test
三、打开新的cmd窗口(消费者)
D:\Project\分布式\kafka_2.13-2.4.0\bin\windows> .\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
在第二个窗口,输入内容,则第三个窗口便可看到