zoukankan      html  css  js  c++  java
  • 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即可

  • 相关阅读:
    三维重建:SLAM算法的考题总结
    ubuntu16.04安装KDE
    pip更新
    DNN结构演进History—CNN-GoogLeNet :Going Deeper with Convolutions
    OpenCV直方图均衡化
    图像连通域检测的2路算法Code
    OpenCV中的模板匹配/Filter2d
    OpenCV边缘检测的详细参数调节
    ICCV2015上的GazeTracker论文总结
    图像的连通域检测的堆栈算法
  • 原文地址:https://www.cnblogs.com/cdlyy/p/14411742.html
Copyright © 2011-2022 走看看