作者写的很好,转载不需多言,强调java版本一定不要随便改

  1. 安装JDK
    1.1 安装文件:http://www.oracle.com/technetwork/java/javase/downloads/index.html 下载JDK
    1.2 安装完成后需要添加以下的环境变量(右键点击“我的电脑” -> “高级系统设置” -> “环境变量” ):

JAVA_HOME: C:\Program Files\Java\jdk1.8.0_171 (jdk的安装路径)
Path: 在现有的值后面添加"; %JAVA_HOME%\bin"
1.3 打开cmd运行 “java -version” 查看当前系统Java的版本:

  1. 安装ZOOKEEPER
    Kafka的运行依赖于Zookeeper,所以在运行Kafka之前我们需要安装并运行Zookeeper

2.1 下载安装文件: http://zookeeper.apache.org/releases.html
2.2 解压文件
2.3 打开zookeeper-3.4.13\conf,把zoo_sample.cfg重命名成zoo.cfg
2.4 从文本编辑器里打开zoo.cfg
2.5 把dataDir的值改成“./zookeeper-3.4.13/data”
2.6 添加如下系统变量:
ZOOKEEPER_HOME: C:\Users\localadmin\CODE\zookeeper-3.4.13 (zookeeper目录)
Path: 在现有的值后面添加 “;%ZOOKEEPER_HOME%\bin;”
2.7 运行Zookeeper: 打开cmd然后执行 zkserver

cmd 窗口不要关闭

  1. 安装并运行KAFKA
    3.1 下载安装文件: http://kafka.apache.org/downloads.html
    3.2 解压文件
    3.3 打开kafka_2.11-2.0.0\config
    3.4 从文本编辑器里打开 server.properties
    3.5 把 log.dirs的值改成 “./logs”
    3.6 打开cmd
    3.7 进入kafka文件目录: cd C:\Users\localadmin\CODE\kafka_2.11-2.0.0(kafka目录)
    3.8 输入并执行: .\bin\windows\kafka-server-start.bat .\config\server.properties

cmd 窗口不要关闭

  1. 创建TOPICS
    4.1 打开cmd 并进入cd C:\Users\localadmin\CODE\kafka_2.11-2.0.0\bin\windows
    4.2 创建一个topic: kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

  2. 打开一个PRODUCER:
    cd C:\Users\localadmin\CODE\kafka_2.11-2.0.0\bin\windows
    kafka-console-producer.bat --broker-list localhost:9092 --topic test

  3. 打开一个CONSUMER:
    cd C:\Users\localadmin\CODE\kafka_2.11-2.0.0\bin\windows
    kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

  4. 测试:

本文版权归作者和博客园共有,欢迎转载,但未经作者同意需保留此段声明,且在文章页面明显位置给出原文连接。

作者:Lnice
出处:http://www.cnblogs.com/lnice

WINDOWS上KAFKA运行环境安装相关推荐

  1. 迅雷U享php文件怎么打开,windows下php运行环境安装配置

    前言:因为都是基础的东西所以大神请绕道! 一.软件准备 以下地址仅供参考 apache http://www.duote.com/downsite/993.html mysql  http://xia ...

  2. Windows上python开发--2安装django框架

    Windows上python开发--2安装django框架 分类: 服务器后台开发2014-05-17 21:22 2310人阅读 评论(2) 收藏 举报 python django 上一篇文章中讲了 ...

  3. 在Windows上双击运行Python程序不会自动退出的方法

    文章目录 在Windows上双击运行Python程序不会自动退出的方法 前言 将python.exe添加到环境变量中 一个Python程序例子 双击运行Python程序报错 双击运行Windows C ...

  4. 在windows上用源代码编译安装MPlayer

    转自:http://www.cnblogs.com/smallmuda/archive/2009/03/31/1425976.html 在windows上用源代码编译安装MPlayer 作者:心情花园 ...

  5. 如何在 Windows 上的 VirtualBox 中安装 macOS Big Sur

    [手把手]如何在 Windows 上的 VirtualBox 中安装 macOS Big Sur 零.软件环境前提准备 一.准备安装 1.在您的计算机上安装 VirtualBox 软件.之后,单击您下 ...

  6. 在windows上模拟linux环境,Windows下使用NCL(Cygwin模拟Linux环境)

    参考自:http://bbs.lasg.ac.cn/bbs/thread-37043-1-1.html 1.下载 所需文件均可在此下载:http://yunpan.cn/cQsvAEe3Axs2Z   ...

  7. 漫游Kafka实战篇之搭建Kafka运行环境

    原文地址:http://blog.csdn.net/honglei915/article/details/37564329 Kafka视频教程同步首发,欢迎观看! 接下来一步一步搭建Kafka运行环境 ...

  8. 【Qt开发】Qt Creator在Windows上的调试器安装与配置

    Qt Creator在Windows上的调试器安装与配置 如果安装Qt时使用的是Visual Studio的预编译版,那么很有可能就会缺少调试器(Debugger),而使用MSVC的Qt对应的原生调试 ...

  9. Windows上同时运行两个Tomcat

    步骤 1.获得免安装包 从Tomcat官网下载免安装包. 2.解压复制 解压并创建两个副本tomcat1和tomcat2,它们的路径分别为: tomcat1:C:\tomcat\double\apac ...

最新文章

  1. Windows Mobile下访问Sqlite的Native C++封装
  2. springboot+springsecurity+mybatis plus之用户授权
  3. c语言共享内存,在爷儿俩进程间使用共享内存(共享内容含指针)
  4. 探求Floyd算法的动态规划本质
  5. jBPM4工作流应用开发指南
  6. 百度云OCR身份证识别
  7. android5.1导航系统,北斗地图导航系统
  8. 以太网链路捆绑原理实验
  9. Linux实现基于Loopback的NVI(NAT Virtual Interface)
  10. 为什么利率上升,债券价格下降?
  11. vscode能写winform窗体吗_vs code 写C#心得
  12. 【富文本】wangeditor编辑器简单使用(自定义图片上传)
  13. 苹果系列产品文件共享神器
  14. jump label
  15. 如何查看office是否是永久激活
  16. linux usb 全向麦克风,推崇金典款的适合80平方中小会议室使用的USB有线会议阵列麦克风...
  17. 网站被流量攻击了,如何解决
  18. java 布尔值变成字符串,Java将布尔值转换为字符串
  19. 树莓派CM4 Sensing(包含485接口)+python+继电器+水质仪+阿里云物联网平台ito实现实时检测水质并上传数据到阿里云ito和远程控制灯光
  20. DVWA-SQL盲注 medium

热门文章

  1. 一张图看懂CSS cascade, specific, importance, inheritance
  2. 学习笔记-记ActiveMQ学习摘录与心得(一)
  3. 2013ACM暑假集训总结-致将走上大三征途的我
  4. 教你认识H3C的设备
  5. 系统的MAC地址修改
  6. 算法训练 未名湖边的烦恼
  7. 《机器学习实战》chapter06 支持向量机
  8. Ubuntu16.04下Hadoop 2.7.3的安装与配置
  9. Java使用strategy模式构造程序
  10. OperationalError: (1044, Access denied for user ''@'localhost' to database 'mydb')