当前位置: 首页 > news >正文

Win11下搭建Kafka环境

目录

一、环境准备

二、安装JDK

1、下载JDK 

2、配置环境变量

3、验证

三、安装zookeeper

1、下载Zookeeper安装包

2、配置环境变量

3、修改配置文件zoo.cfg

4、启动Zookeeper服务

4.1 启动Zookeeper客户端验证

4.2 启动客户端

四、安装Kafka

1、下载Kafka安装包

2、配置Kafka

3、启动Kafka


一、环境准备

1、JDK

2、Zookeeper

3、Kafka

二、安装JDK

1、下载JDK 

JDK 23  官网下载地址

如下截图,选择windows Tab 下 MSI安装包

2、配置环境变量

安装后配置系统环境变量  JAVA_HOME

开始栏搜索“高级”,修改系统设置

选择【环境变量】

系统变量中,新增【JAVA_HOME】变量,并配置JDK目录

系统变量中,修改【Path】变量,增加Java配置

%JAVA_HOME%\bin

3、验证

保存环境变量后,打开CMD验证是否完成安装及配置。

CMD 输入

 java -version

如图所示,即为安装成功。

三、安装zookeeper

1、下载Zookeeper安装包

Apache官网下载zookeeper,下载地址

下载完成后解压,复制到需要放置的目录下重命名即可,如D:\Serve\apache-zookeeper-3.9.3

2、配置环境变量

系统环境变量中新增ZOOKEEPER_HOME环境变量

将环境变量配置到Path变量中

添加:%ZOOKEEPER_HOME%\bin

3、修改配置文件zoo.cfg

打开conf目录,复制zoo.example.cfg文件并重命名为zoo.cfg文件,并编辑文件内容

dataDir=D:\Serve\apache-zookeeper-3.9.3\data
dataLogDir=D:\Serve\apache-zookeeper-3.9.3\logs

# admin管理端端口
admin.serverPort=9091
audit.enable=true

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=D:\Serve\apache-zookeeper-3.9.3\data
dataLogDir=D:\Serve\apache-zookeeper-3.9.3\logs
# the port at which the clients will connect
clientPort=2181
# admin管理端端口
admin.serverPort=9091
audit.enable=true
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the 
# administrator guide before turning on autopurge.
#
# https://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1## Metrics Providers
#
# https://prometheus.io Metrics Exporter
#metricsProvider.className=org.apache.zookeeper.metrics.prometheus.PrometheusMetricsProvider
#metricsProvider.httpHost=0.0.0.0
#metricsProvider.httpPort=7000
#metricsProvider.exportJvmInfo=true

4、启动Zookeeper服务

4.1 启动Zookeeper客户端验证

双击zkCli.cmd

如果出现:[zk: localhost:2181(CONNECTED) 0]说明成功。

4.2 启动客户端

打开D:\Serve\apache-zookeeper-3.9.3\bin  目录,双击zkServer.cmd

显示上图且最后显示success,即为成功!

四、安装Kafka

1、下载Kafka安装包

官网下载安装包,下载地址

下载后解压缩并重命名即可。

2、配置Kafka

修改Kafka配置文件,config目录下的server.properties文件。

3、启动Kafka

CMD进入Kafka目录下,输入下列指令

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

显示如下配置后,则表示启动成功

http://www.lryc.cn/news/534359.html

相关文章:

  • MacBook Pro M2安装deepseek
  • springboot的http请求不通原因
  • 【Windows】PowerShell 缓存区大小调节
  • 使用python脚本批量删除redis缓存
  • Python截图轻量化工具
  • Android图片加载框架Coil,Kotlin
  • 重生之我要当云原生大师(十四)分析和存储日志
  • C++基础知识学习记录—补充
  • Linux常用命令——磁盘管理类
  • 【AI学习】DeepSeek为什么强?
  • 【快应用】原生广告下载状态监听案例
  • C++语言的软件工程
  • 计算机网络结课设计:通过思科Cisco进行中小型校园网搭建
  • 无人机避障——基于ESDF地图的JPS算法前端路径规划
  • 【MQ】RabbitMQ 高可用延时功能的探究
  • Maven入门核心知识点总结
  • 【力扣】138.随机链表的复制
  • 编程语言的深度剖析:从语法到性能优化
  • 台湾精锐APEX减速机在半导体制造设备中的应用案例
  • Rocketmq 和 Rabbitmq ,在多消费者的情况下,可以实现顺序消费吗
  • Springboot原理(面试高频)
  • 2024 Rust现代实用教程:1.1Rust简介与安装更新
  • yolov11模型在Android设备上运行【踩坑记录】
  • 提示工程:少样本提示(Few-shot Prompting)
  • 方舟字节码原理剖析:架构、特性与实践应用
  • 深入Linux系列之环境变量
  • 国产编辑器EverEdit - Web预览功能
  • C#中的Frm_Welcome.Instance.Show(),是什么意思
  • 07苍穹外卖之redis缓存商品、购物车(redis案例缓存实现)
  • C++开发(软件开发)常见面试题