zoukankan      html  css  js  c++  java
  • kafka环境搭建(windows)

    kafka环境搭建(windows)

    原文引用:https://www.jianshu.com/p/f7037105db46

    zookeeper

    • 解压E:studykafka_workzookeeper-3.4.12,创建data文件夹

      1527840168103

    • 进入到conf目录,然后复制zoo_sample.cfg为zoo.cfg

    • 1527840259527

    修改zoo.cfg中的dataDir

    1527840343846

    • 启动Zookeeper,进入 bin 目录,执行 zkServer.cmd

      1527840452421

    Kafka

    • 解压,建立一个空文件夹 logs

      1527840597418

    ###

    • 进入config目录,编辑 server.properties 文件

      1527840638873

    修改log.dirs

    1527840699576

    运行

    • cmd进入kafka文件夹,我的是E:studykafka_workkafka_2.12-1.1.0,执行下面命令

      .inwindowskafka-server-start.bat .configserver.properties

    1527840858400

    注意:如果遇到上图无法加载主类问题,请执行SET CLASSPATH=.;

    测试

    • cmd 进入E:studykafka_workkafka_2.12-1.1.0inwindows目录,创建一个topic

      
       

      1

      
       

      kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test.topic

    打开一个Producer

    
     

    1

    
     

    kafka-console-producer.bat --broker-list localhost:9092 --topic test.topic

    1527841299963

    • 执行命令,打开生产者

      
       

      1

      
       

      kafka-console-consumer.bat --zookeeper localhost:2181 --topic test.topic

      1527841450736

    • 现在有4个cmd窗口,
      1. zookeeper
      2. kafka
      3. producer
      4. consumer
    • 下面,我们在3号窗口(Producer)输入一些字符,就会看到4号窗口马上就收到消息

    1527841688385

    注意事项

    • 在搭建时如果提示: 错误: 找不到或无法加载主类 FilesJavajdk1.8.0_141libdt.jar;D:Program,请执行命令 set classpath=.;
    • zookeeper 默认端口号为 2181
    • kafka 默认端口号为 9092
    • produce(发送消息者)启动时参数使用的是kafka的端口号(默认9092),而consumer(接收消息者)启动时使用的是zookeeper端口号(默认2181)
  • 相关阅读:
    【正则】——作业计算数学运算
    【面向对象】-类和对象作业
    【递归】
    笔记本linux问题记录
    监听器模式(Listener)
    Java引用类型
    Dubbo-服务发布-本地暴露/远程暴露
    完成一个Spring的自定义配置
    Dubbo SPI-Adaptive详解
    Dubbo-动态编译
  • 原文地址:https://www.cnblogs.com/tzeyeung/p/13531331.html
Copyright © 2011-2022 走看看