首页
学习
活动
专区
圈层
工具
发布
社区首页 >专栏 >Linux安装Kafka(无Zookeeper模式)保姆级教程,云服务器安装部署,Windows内存不够可以看看

Linux安装Kafka(无Zookeeper模式)保姆级教程,云服务器安装部署,Windows内存不够可以看看

作者头像
程序员三明治
发布2025-12-18 20:33:31
发布2025-12-18 20:33:31
7050
举报
文章被收录于专栏:码力up码力up
1、下载kafka安装包:https://kafka.apache.org/downloads.html

然后移动到linux指定的目录中:

2、解压,这里我放到/opt下

tar -zxvf kafka_2.12-3.9.1.tgz -C/opt/

3.修改配置:

因为我们不使用zookeeper,所以来到kafka装根目录的下的/config/kraft/

cd /opt/kafka_2.12-3.9.1/config/kraft/

vi server.properties

我这里只修改了日志路径:

log.dirs=/opt/kafka_2.12-3.9.1/data/kafka34.生成集群id

进入bin目录下,输入命令生成集群id

代码语言:javascript
复制
kafka-storage.sh random-uuid

得到一个uuid:

I_p69ZTITRmhtpbLW-uGfA

5.格式化目录
代码语言:javascript
复制
kafka-storage.sh format -t I_p69ZTITRmhtpbLW-uGfA -c /opt/kafka_2.12-3.9.1/config/kraft/server.properties

格式化操作完成之后,你会发现在我们定义的log.dirs目录下多出一个meta.properties文件。meta.properties文件中存储了当前的kafka节点的id(node.id),当前节点属于哪个集群(cluster.id

代码语言:javascript
复制
#
#Fri Sep 19 22:29:13 CST 2025
node.id=1
directory.id=CobSxEpYanh30ipW5nmYZw
version=1
cluster.id=I_p69ZTITRmhtpbLW-uGfA
6.启动
代码语言:javascript
复制
cd /opt/kafka_2.12-3.9.1/bin
./kafka-server-start.sh ../config/kraft/server.properties

会滚动打印很长的日志

7.验证安装

进入bin目录下

代码语言:javascript
复制
# 创建主题
./kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
代码语言:javascript
复制
# 查看主题列表
./kafka-topics.sh --list --bootstrap-server localhost:9092
代码语言:javascript
复制
# 查看主题详情
./kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

发送测试消息:

代码语言:javascript
复制
# 启动生产者控制台
./kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

接收消息:

代码语言:javascript
复制
# 启动消费者控制台
./kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
如何让Kafka在服务器后台运行

配置sytemctl

进入到目录/lib/systemd/system/下:

代码语言:javascript
复制
cd /lib/systemd/system/

编辑文件 kafka.service

代码语言:javascript
复制
vim kafka.service

填写如下内容

代码语言:javascript
复制
[Unit]
Description=Apache Kafka Server
Documentation=https://kafka.apache.org/
After=network.target

[Service]
Type=forking
User=root
Group=root
Environment="JAVA_HOME=/usr/local/jdk17.0.8.1"
Environment="PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin"
ExecStart=/opt/kafka_2.12-3.9.1/bin/kafka-server-start.sh -daemon /opt/kafka_2.12-3.9.1/config/kraft/server.properties
Restart=on-failure
RestartSec=10
 
[Install]
WantedBy=multi-user.target

保存,退出编辑

代码语言:javascript
复制
wq

刷新sytemctl配置

代码语言:javascript
复制
systemctl daemon-reload

启动kafka

代码语言:javascript
复制
systemctl start kafka

查看kafka服务状态

代码语言:javascript
复制
systemctl status kafka

出现 Active: active (running) 字样表示启动成功,否则表示启动失败!如下图所示:

配置开机自启动

代码语言:javascript
复制
systemctl enable kafka

停止kafka命令(如果需要停止)

代码语言:javascript
复制
systemctl stop kafka

如果我的内容对你有帮助,请辛苦动动您的手指为我点赞,评论,收藏。感谢大家!!

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2025-09-20,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1、下载kafka安装包:https://kafka.apache.org/downloads.html
  • 2、解压,这里我放到/opt下
  • 3.修改配置:
  • 5.格式化目录
  • 6.启动
  • 7.验证安装
  • 如何让Kafka在服务器后台运行
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档