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

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.kler.cn/a/538619.html

相关文章:

  • Linux之kernel(4)netlink通信
  • 《ARM64体系结构编程与实践》学习笔记(四)
  • 智能化食品安全管理:AI视频监控在大型商场的技术方案
  • 青少年编程与数学 02-009 Django 5 Web 编程 03课题、项目结构
  • 2.9寒假作业
  • DeepSeek-R1 论文解析——人工智能领域的 RL LLM 新时代?
  • 2. UVM的基本概念和架构
  • 深度学习在医疗影像分析中的应用
  • [Meet DeepSeek] 如何顺畅使用DeepSeek?告别【服务器繁忙,请稍后再试。】
  • 前端【技术方案】浏览器兼容问题(含解决方案、CSS Hacks、条件注释、特性检测、Polyfill 等)
  • SQL写法:行行比较
  • 【R语言】数据分析
  • fatal:Authentication failed for “http....
  • 现在中国三大运营商各自使用的哪些band频段
  • 【Pycharm+Git+Gitlab】安装部署(粗糙版)
  • 电脑黑屏按什么键恢复?电脑黑屏的解决办法
  • [Redis] Redis分布式锁与常见面试题
  • Nginx中替换即将到期的SSL/TLS证书
  • 【开发电商系统的技术选型】
  • ArgoCD实战指南:GitOps驱动下的Kubernetes自动化部署与Helm/Kustomize集成
  • 【ArcGIS】R语言空间分析、模拟预测与可视化技术
  • 问卷数据分析|SPSS之数据导入及变量设置
  • 在AWS上设计与实现个人财务助理的Web应用程序
  • Gradle 发布Jar到 Maven Central
  • [oeasy]python064_命令行工作流的总结_vim_shell_python
  • 腾讯混元3D创作引擎:一站式AI 3D创作平台的深度解析