Kafka2.12-2.5.0在windows环境的安装 启动 通信测试

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. 第二步② 启动可能会遇到的错误

问题描述: win10启动kafka报错: ERROR Failed to clean up log for __consumer_offsets-39 in dir d:Kafkakafka_2.12-2.5.0inwindowsKafkakafka_2.12-2.5.0logs due to IOException (kafka.server.LogDirFailureChannel) java.nio.file.FileSystemException:

d:Kafkakafka_2.12-2.5.0inwindowsKafkakafka_2.12-2.5.0logs__consumer_offsets-390000000000000000000.timeindex.cleaned: 另一个程序正在使用此文件,进程无法访问。

原因: 可能是由于非正常关闭, 导致kafka无法完成对日志文件的解锁

解决方法: 错误信息中指出了日志的存放路径, 我这里是d:Kafkakafka_2.12-2.5.0inwindowsKafkakafka_2.12-2.5.0logs

, 将这个目录下的所有文件删除后重新启动kafka即可

原文地址:https://www.cnblogs.com/cdlyy/p/14411742.html