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