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即可

  • 相关阅读:
    点击区域外隐藏该区域,event.stopPropagation()
    PHP 笔记一(systax/variables/echo/print/Data Type)
    <hr> 的18种样式
    CSS 设置背景透明度,不影响子元素
    console.dir() 与 console.log() 区别
    JS 鼠标滚轮事件(mousewheel/DOMMouseScroll)
    HTML 字符图案
    CSS 样式优先级
    替换元素和不可替换元素,块级元素和行内元素
    CSS3 笔记五(Buttons)
  • 原文地址:https://www.cnblogs.com/cdlyy/p/14411742.html
Copyright © 2011-2022 走看看