Win11下搭建Kafka环境

server/2025/2/12 6:46:14/

目录

一、环境准备

二、安装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.ppmy.cn/server/166983.html

相关文章

PHP音视频课程培训系统

📚 音视频课程培训系统——为您量身定制的智慧学习空间 🔧 这是一款匠心独运的课程培训系统,基于ThinkPHP与Uniapp先进框架精心构筑。它不仅集成了音视频课程点播、付费文档获取、活动报名等多元化功能,更致力于为您打造一站式、…

Vue项目能进行哪些性能优化?

一、前言 在新公司开发项目的时候,我发现总结了一个问题就是,当我开发完某个需求。但是当测试完开发完产品验收的时候可能会从性能方面验收的时候会出现一些你意想不到的结果。为此我整理一下项目中优化可以从哪些方面来入手。首先可以从三个方面来进行…

基于离散小波变换的深度学习神经网络在肝细胞癌自动超声成像中的应用| 文献速递-医学影像人工智能进展

Title 题目 Automated ultrasonography of hepatocellular carcinoma using discrete wavelet transform based deep-learning neural network 基于离散小波变换的深度学习神经网络在肝细胞癌自动超声成像中的应用 01 文献速递介绍 全球健康挑战:肝细胞癌的诊断…

effective-Objective-C 第五章学习笔记

内存管理 文章目录 内存管理理解引用计数属性存取方法的内存管理自动释放池要点 以ARC简化引用计数使用ARC时必须遵循的方法命名规则变量的内存管理语义ARC清理实例变量覆写内存管理方法要点 在dealloc方法中只释放引用并解除监听要点 编写异常安全代码时留意内存管理问题要点 …

【从零开始入门unity游戏开发之——C#篇57】C#补充知识点——C#9 记录类型(Records)与模式匹配详解

考虑到每个人基础可能不一样,且并不是所有人都有同时做2D、3D开发的需求,所以我把 【零基础入门unity游戏开发】 分为成了C#篇、unity通用篇、unity3D篇、unity2D篇。 【C#篇】:主要讲解C#的基础语法,包括变量、数据类型、运算符、流程控制、面向对象等,适合没有编程基础的…

接口测试Day12-持续集成、git简介和安装、Gitee远程仓库、jenkins集成

持续集成 概念: 团队成员将自己的工作成果,持续集成到一个公共平台的过程。成员可以每天集成一次,也可以一天集成多 次。 相关工具: 本地代码管理:git远程代码管理:gitee(国内)、github(国外)、gitlib(公司…

C++性能优化—AI润色版

上接《C性能优化—人工底稿版》 C性能优化深度解析:从编码技巧到硬件协同 "过早优化是万恶之源" —— Donald Knuth 但合理的性能优化是优秀C工程师的核心能力。本文从编码实践到硬件原理,系统梳理C性能优化的知识体系。 一、性能优化的哲学…

【ThreeJS Basics 1-3】Hello ThreeJS,实现第一个场景

文章目录 环境创建一个项目安装依赖基础 Web 页面概念解释编写代码运行项目 环境 我的环境是 node version 22 创建一个项目 首先,新建一个空的文件夹,然后 npm init -y , 此时会快速生成好默认的 package.json 安装依赖 在新建的项目下用 npm 安装依…