前言

本搭建不涉及整合 只是一个简单的本地环境的搭建,跟大家一起学习,搭建的目的是项目中(java)需要用到,默认环境已经装好JDK,没有搭建jdk的可以参考其他文章

环境准备

  • zookeeper

  1. 下载 http://zookeeper.apache.org/releases.html#download   此文档使用版本https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz
  2. 解压并修改zoo_sample.config 为zoo.config
    Windows 环境kafka环境搭建及可能遇到的问题(zookeeper is not a recognized option)
  3. 编辑zoo.config,修改dataDir为你的自定义路径
    Windows 环境kafka环境搭建及可能遇到的问题(zookeeper is not a recognized option)
  4. 为zookeeper添加环境变量
    ZOOKEEPER_HOME=D:\code\zookeeper\zookeeper-3.4.14(根据自己的安装位置)
    path添加  %ZOOKEEPER_HOME%\bin
  5. cmd(直接win+r)
    zkserver
    Windows 环境kafka环境搭建及可能遇到的问题(zookeeper is not a recognized option)

        到这里  zookeeper已经搭建完毕

  • kafaka

  1. 下载http://kafka.apache.org/downloads,记得下载二进制版本 (本文使用版本https://archive.apache.org/dist/kafka/2.4.0/kafka_2.12-2.4.0.tgz.asc
  2. 解压,并来到D:\code\kafka\kafka_2.12-2.4.0\config 文件下,修改 log.dirs=D:/code/kafka/kafka_2.12-2.4.0/log(你自定义的位置)
    Windows 环境kafka环境搭建及可能遇到的问题(zookeeper is not a recognized option)
  3. 来到D:\code\kafka\kafka_2.12-2.4.0 (你的安装目录)输入cmd
    执行: .\bin\windows\kafka-server-start.bat .\config\server.properties   启动kafkaserver (注意前面的zk也是要启动的哦)
    Windows 环境kafka环境搭建及可能遇到的问题(zookeeper is not a recognized option)
  4. 来到D:\code\kafka\kafka_2.12-2.4.0\bin\windows  单开一个cmd 创建一个topic
    kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demohah

    Windows 环境kafka环境搭建及可能遇到的问题(zookeeper is not a recognized option)
  5.  到D:\code\kafka\kafka_2.12-2.4.0\bin\windows 目录下,再单独开一cmd ,创建生产者

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

    Windows 环境kafka环境搭建及可能遇到的问题(zookeeper is not a recognized option)
  6.  到D:\code\kafka\kafka_2.12-2.4.0\bin\windows 目录下,再单独开一cmd ,创建消费者

    kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demohah

    Windows 环境kafka环境搭建及可能遇到的问题(zookeeper is not a recognized option)
     
  7. 现在就可以愉快的测试了,上图在生产者中输入消息 消费者已经收到,完工
  • 遇到的问题

  1. 新版本kafka(0.9之后)消费者启动使用
    kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic {你的topic名字}

    我按之前网上的步骤 用命令

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

    发现 zookeeper中一直显示日志  no session established for client,消费者也没有收到消息,用了新命令启动就好了

    推荐文章:
    http://www.iocoder.cn/Kafka/install/?self
     

相关文章:

  • 2022-12-23
  • 2021-08-01
  • 2021-12-12
  • 2022-02-24
  • 2021-06-27
  • 2021-06-01
猜你喜欢
  • 2021-04-07
  • 2022-12-23
  • 2021-09-18
  • 2021-11-24
  • 2021-06-29
  • 2021-12-08
  • 2021-10-12
相关资源
相似解决方案