Windows安装Kafka

1.安装JDK并配置好对应的环境变量

在这里插入图片描述

● 新建一个文件夹jre
在这里插入图片描述

● 1.环境变量如下-安装的路径
在这里插入图片描述

● 2.点击path新建
在这里插入图片描述

● 3.建一个系统变量
在这里插入图片描述

.;%JAVA_HOME%\lib;%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\tools.jar

2.安装配置Zookeeper

1.下载安装包Apache Zookeeper

下载

2.解压并进入Zookeeper目录

● 2.1将conf下的zoo_sample.cfg重命名为 zoo.cfg
在这里插入图片描述

● 2.2 打开zoo.cfg,修改数据存放位置dataDir
dataDir=D:/OnlineSoftWare/apache-zookeeper-3.7.1/data

dataDir=D:/OnlineSoftWare/apache-zookeeper-3.7.1/data
# 防止端口8080启动后被占用,这里考虑先配置下
admin.serverPort=8081

防止端口8080启动后被占用,这里考虑先配置下

admin.serverPort=8081
在这里插入图片描述

● 2.3 添加系统变量
在这里插入图片描述

● 2.4在path新建一个
在这里插入图片描述

3.打开新的cmd,输入"zkServer",运行Zookeeper
在这里插入图片描述

● 只要不报错就是成功,如果报错下面这个只需要把2.2的admin端口配置了

Caused by: java.io.IOException: Failed to bind to /0.0.0.0:8080
    at org.eclipse.jetty.server.ServerConnector.openAcceptChannel(ServerConnector.java:346)
    at org.eclipse.jetty.server.ServerConnector.open(ServerConnector.java:308)
    at org.eclipse.jetty.server.AbstractNetworkConnector.doStart(AbstractNetworkConnector.java:80)
    at org.eclipse.jetty.server.ServerConnector.doStart(ServerConnector.java:236)
    at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)
    at org.eclipse.jetty.server.Server.doStart(Server.java:396)
    at org.eclipse.jetty.util.component.AbstractLifeCycle.start(AbstractLifeCycle.java:68)
    at org.apache.zookeeper.server.admin.JettyAdminServer.start(JettyAdminServer.java:103)
    ... 5 more
Caused by: java.net.BindException: Address already in use: bind
        at sun.nio.ch.Net.bind0(Native Method)
        at sun.nio.ch.Net.bind(Net.java:433)
        at sun.nio.ch.Net.bind(Net.java:425)
        at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)
        at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:74)
        at org.eclipse.jetty.server.ServerConnector.openAcceptChannel(ServerConnector.java:342)
        ... 12 more
Unable to start AdminServer, exiting abnormally

注意不能关闭这个接口~因为kafka需要先启动zookeeper!

3.安装Kafka

3.1 下载安装包

Kafka下载
下载二进制版本,如图
在这里插入图片描述

3.2、 解压并进入Kafka目录,

笔者:D:\OnlineSoftWare\kafka_2.13-3.3.1
在这里插入图片描述

3、 进入config目录找到文件server.properties并打开
找到并编辑日志保存的位置 log.dirs、listener,其中kafka-logs是自己新建的文件夹

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://localhost:9092
log.dirs=D:\OnlineSoftWare\kafka_2.13-3.3.1\kafka-logs
broker.id=1

在这里插入图片描述

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

在这里插入图片描述

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

在这里插入图片描述

到这里就安装完毕了!

linux下安装的还在编写中…

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐