1 安装zookeeper

1、 下载安装包
http://zookeeper.apache.org/releases.html#download
https://www.apache.org/dyn/closer.cgi/zookeeper/

一定要认准bin版,apache-zookeeper-3.5.5-bin

如果没有使用bin版本,在运行时可能会报:错误: 找不到或无法加载主类 org.apache.zookeeper.server.quorum.QuorumPeerMain

2、 解压并进入ZooKeeper目录,比如:C:\Workspace\kafka\apache-zookeeper-3.5.5-bin\conf

3、 将“zoo_sample.cfg”重命名为“zoo.cfg”

4、 打开“zoo.cfg”找到并编辑dataDir=C:\Workspace\kafka\zookeeper_data

5、 添加系统变量:ZOOKEEPER_HOME=C:\Workspace\kafka\apache-zookeeper-3.5.5-bin

6、 编辑Path系统变量,添加路径:%ZOOKEEPER_HOME%\bin

7、 在zoo.cfg文件中修改默认的Zookeeper端口(默认端口2181)

8、 打开新的cmd,输入“zkServer“,运行Zookeeper

9、 命令行提示如下:说明本地Zookeeper启动成功

image.png

2 安装Kafka

1、 下载安装包

http://kafka.apache.org/downloads
注意要下载二进制版本 Binary downloads

2、 解压并进入Kafka目录,C:\Workspace\kafka\kafka_2.12-2.3.0

3、 进入config目录找到文件server.properties并打开

4、 找到并编辑log.dirs=C:\Workspace\kafka\kafka_2.12-2.3.0\kafka-logs

5、 找到并编辑zookeeper.connect=localhost:2181

6、 Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181

7、 进入Kafka安装目录D:\Kafka\kafka_2.12-0.11.0.0,按下Shift+右键,选择“打开命令窗口”选项,打开命令行,输入:

.\bin\windows\kafka-server-start.bat .\config\server.properties

如果出现

Windows CMD命令行解释器【输入行太长。 命令语法不正确】

这是一个很少见的错误,我在全网搜,大多都是在%CLASSPATH%改成"%CLASSPATH%",但我发现kafka已经帮我们做了这一步了。那为什么我还会报这个错呢?

参考:https://support.microsoft.com/zh-cn/help/830473/command-prompt-cmd-exe-command-line-string-limitation

  • 使用较短的文件夹和文件的名称。
  • 减少文件夹树的深度。

注意:不要关了这个窗口,启用Kafka前请确保ZooKeeper实例已经准备好并开始运行

3 测试

1、 创建主题,进入Kafka安装目录C:\Workspace\kafka\kafka_2.12-2.3.0\,按下Shift+右键,选择“打开命令窗口”选项,打开命令行,输入:

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

image.png

查看主题输入:
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

image.png

2、 创建生产者,进入Kafka安装目录D:\Kafka\kafka_2.12-0.11.0.0,按下Shift+右键,选择“打开命令窗口”选项,打开命令行,输入:
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

image.png

注意:不要关了这个窗口

3、 创建消费者,进入Kafka安装目录D:\Kafka\kafka_2.12-0.11.0.0,按下Shift+右键,选择“打开命令窗口”选项,打开命令行,输入:
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

image.png

左边生产什么,右边就消费什么

4、 大功告成

作者:河的左岸
链接:https://www.jianshu.com/p/fc27649a8030
来源:简书
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

Kafka安装(windows)相关推荐

  1. kafka安装(windows版)

    一.安装JDK 过程比较简单,就不在详细说明 二.安装zookeeper # 1.下载安装包 https://zookeeper.apache.org/releases.html#download # ...

  2. SpringBoot之kafka安装windows

    首先安装kafka,由于我是windows安装的,所以下载安装包: 配置zookeeper 首先配置环境变量 添加JAVA_HOME 增加ZOOKEEPER_HOME的环境变量 ZOOKEEPER_H ...

  3. kafka在Windows系统下的安装出现的错误汇总:

    kafka在Windows系统下的安装出现的部分奇奇怪怪的错误: 假设你渡过了Zookeeper版本和JDK版本问题,出现了如下问题. ①出现了'wmic' 不是内部或外部命令,也不是可运行的程序 或 ...

  4. Kafka单机Windows环境搭建

    Kafka单机Windows环境搭建 1,安装jdk1.8:安装目录不能有中文空格: 2,下载zookeeper,https://mirrors.cnnic.cn/apache/zookeeper/z ...

  5. 【kafka】 windows平台搭建及使用

    一.安装 kafka 需要java环境: kafka 最新版本内置了 zookeeper,所以不需要安装zookeeper: 下载kafka最新版本,因为下载的是tgz文件,所以不需要安装,解压到相应 ...

  6. Kafka安装及部署

    阅读目录 一.环境配置 二.操作过程 Kafka介绍 安装及部署 回到顶部 一.环境配置 操作系统:Cent OS 7 Kafka版本:0.9.0.0 Kafka官网下载:请点击 JDK版本:1.7. ...

  7. 一、kafka安装下载与kafka初步应用

    kafka安装下载 一.Kafka的下载 1.下载地址 Kafka的Windows下的运行 1.启动Zookeeper 2.启动Kafka Kafka的Linux下的运行 Kafka运行占用的端口 二 ...

  8. Kafka安装详细教程

    一.安装Zookeeper 本文以 zookeeper-3.4.10 版本 1.下载 下载地址:https://zookeeper.apache.org/releases.html 2.解压 解压到 ...

  9. Kafka安装以及验证

    文章目录 1 Kafka安装 1.1 下载安装 1.2 配置启动zookeeper 1.3 配置kafka 1.3.1 修改配置文件 1.3.2 配置环境变量 1.3.3 配置服务启动脚本 1.3.4 ...

最新文章

  1. 循环IRNNv2Layer实现
  2. python3 url编码 空格 + 简介
  3. 360无痕浏览器_浏览器如何开启老板键?
  4. win10 docker desktop无法拉取镜像解决办法
  5. 58同城数据库架构最佳实践
  6. qq互联android sdk,qq互联.Android
  7. Spring中RedirectAttributes对象重定向传参
  8. vsftpd的主配置文件是什么linux,vsftpd.conf配置文件详解
  9. 戴志坚接替李小加出任职港交所行政总裁 基本年薪700万港元
  10. python end用法_8种高级的Python列表使用技巧,都给你整理好啦(附实操代码)
  11. 数组、字符串、集合的相互转换
  12. 计算机录入技术五笔输入法教案,五笔输入法教案
  13. c语言fprintf报错,C语言中printf,sprintf和fprintf的区别是什么
  14. 推荐一款串口调试助手(win10,无广告,功能齐全,操作简单)
  15. Leetcode高频题目整理(更新)
  16. 学校计算机教室解说词词,小学各专用教室解说词.doc
  17. 贤鱼的刷题日常【c++动态规划】4978:宠物小精灵之收服
  18. 安装多个版本号jdk后java -version不改变的问题解决
  19. ECCV 2022 | 视觉新任务!AVS:视听分割
  20. 一个登录页面的测试用例(借鉴他人的,方便查阅)

热门文章

  1. MP4文件格式简要解析---代码解析
  2. Pytorch音频分类
  3. P3387 【模板】缩点
  4. r1音箱原生系统更改服务器,低门槛不破坏R1功能改AUX音源电脑喇叭[已更新完整]...
  5. 无法启动此程序,因为计算机中丢失MSVCP120.dll文件、应用程序无法正常启动0xc000007b
  6. E-PUCK机器人-软件
  7. android手游直播怎么推流,安卓手机直播,Total Control手游投屏教程
  8. Python人工智能实例 │ 使用Haar级联进行人脸检测、使用CAMShift算法、光流法进行人脸追踪
  9. hive hive beeline常用参数
  10. 奥鹏计算机19春在线作业,东师多媒体计算机技术19春在线作业2【标准答案】