1. Kafka下载,我使用的版本是2.12-2.5.0 http://kafka.apache.org/downloads
2. 安装
(1)解压到:D:kafkakafka_2.12-2.5.0
(2)新建目录:D:kafkakafka_2.12-2.5.0logs
用来存放Kafka启动相关的日志
(3)修改配置文件:D:kafkakafka_2.12-2.5.0configserver.properties
log.dirs=D:kafkakafka_2.12-2.5.0logs
(4)启动
① 新建cmd窗口启动zookeeper,在目录:D:kafkakafka_2.12-2.5.0inwindows 下执行: zookeeper-server-start.bat ....configzookeeper.properties
② 新建cmd窗口,在目录:D:kafkakafka_2.12-2.5.0inwindows 下执行: kafka-server-start.bat ....configserver.properties
③ 新建cmd窗口创建topic,在目录:D:kafkakafka_2.12-2.5.0inwindows 下执行:kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic pipeK
④ 新建cmd窗口创建消费者,在目录:D:kafkakafka_2.12-2.5.0inwindows 下 执行:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic pipeK--from-beginning
⑤ 新建cmd窗口创建生产者,在目录:D:kafkakafka_2.12-2.5.0inwindows 下执行:kafka-console-producer.bat --broker-list localhost:9092 --topic pipeK
⑥ 在生产者窗口 ⑤ 中输入 消息,然后查看消费者窗口 ④ 的输出结果。
3. 第二步② 启动可能会遇到的错误