Windows下安装与使用Kafka(使用Kafka内置的ZooKeeper图文结合版)
2023年最新的Windows下安装使用Kafka图文教程版、一文即可一次成功,不用为了老版本,不同文章而烦恼、直接用看最新发布的,本文使用的是jdk1.8+zookeeper3.7+kafka2.13-3.31
·
文章目录
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下安装的还在编写中…
更多推荐
已为社区贡献1条内容
所有评论(0)