kafka2.12在windows环境下的单机配置与简单使用

1.

2.解压缩,并新建一个文件夹logs

3.修改config文件夹下的server.properties文件

log.dir = 你新建的logs地址

#这是我的地址,以自己的地址为准
D:/kafka_2.12-2.1.1/kafka_2.12-2.1.1/kafka-logs

4.进入binwindows,打开cmd窗口

里面长这样

5.启动zookeeper(不能关闭窗口)

zookeeper-server-start.bat ....configzookeeper.properties

6.再开一个窗口,启动kafka(不能关闭窗口)

kafka-server-start.bat ....configserver.properties

7.再开一个窗口,创建一个topic(可以关闭窗口)

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic myTest

8.再开一个窗口,启动消费者(不能关闭窗口)

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic myTest --from-beginning

这里看起来没什么反应,但你无法输入即为成功

9.再开一个窗口,启动生产者(不能关闭窗口)

kafka-console-producer.bat --broker-list localhost:9092 --topic myTest

这里成功有个箭头,可以输入消息

在生产者窗口里输入消息,即可在消费者窗口看到,此时为成功。

生产者输入myTest

消费者收到myTest

经验分享 程序员 微信小程序 职场和发展