下载kafka包,官网
解压出来。我的版本是2.6
要启动kafka,要先启动zookeeper,这里使用kafka自带的zookeeper。
修改config目录下的server.properties文件,修改
log.dirs=F:\kafka_2.13-2.6.0\kafkaLogs
可以新建一个文件夹用来存放kafka的数据信息存放地址。
修改config目录下的log4j.properties文件,修改
log4j.appender.kafkaAppender.File=F:/kafka_2.13-2.6.0/logs/server.log
修改config目录下的zookeeper.properties文件,加入或者修改
dataDir=F:\kafka_2.13-2.6.0\data\zookeeper
配置文件到这里就可以了。
先开始启动zookeeper,在bin/windows目录下打开命令行,输入
zookeeper-server-start.bat ../../config/zookeeper.properties
zookeeper启动成功后,启动kafka:
kafka-server-start.bat ../../config/server.properties
kafka启动成功后,创建一个topic:
kafka-run-class.bat kafka.admin.TopicCommand --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic hellotest
topic的名字是hellotest。
创建生产者:
kafka-console-producer.bat --broker-list localhost:9092 --topic hellotest
然后在生产者窗口中就可以发消息了。
然后创建消费者:
kafka-console-consumer.bat --zookeeper localhost:2181 --topic hellotest --from-beginning
报错了,说是zookeeper is not a recognized option。
查了下因为版本,zookeeper命令已经不再使用了
修改命令为:
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic hellotest --from-beginning
启动成功,接收到了刚才发的消息了
然后在生产者中再次输入消息,消费者窗口中就可以立刻接受到了。
完成