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

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

目录

1、下载kafka安装包:https://kafka.apache.org/downloads.html

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

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

3.修改配置:

5.格式化目录

6.启动

7.验证安装

如何让Kafka在服务器后台运行


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

kafka-storage.sh random-uuid

得到一个uuid:

I_p69ZTITRmhtpbLW-uGfA

5.格式化目录

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

#
#Fri Sep 19 22:29:13 CST 2025
node.id=1
directory.id=CobSxEpYanh30ipW5nmYZw
version=1
cluster.id=I_p69ZTITRmhtpbLW-uGfA

6.启动

cd /opt/kafka_2.12-3.9.1/bin
./kafka-server-start.sh ../config/kraft/server.properties

会滚动打印很长的日志

7.验证安装

进入bin目录下

# 创建主题
./kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

# 查看主题列表
./kafka-topics.sh --list --bootstrap-server localhost:9092

# 查看主题详情
./kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

发送测试消息:

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

接收消息:

# 启动消费者控制台
./kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

如何让Kafka在服务器后台运行

配置sytemctl

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

cd /lib/systemd/system/

编辑文件 kafka.service

vim kafka.service

填写如下内容

[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

保存,退出编辑

wq

刷新sytemctl配置

systemctl daemon-reload

启动kafka

systemctl start kafka

查看kafka服务状态

systemctl status kafka

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

配置开机自启动

systemctl enable kafka

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

systemctl stop kafka

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

http://www.rkmt.cn/news/11660.html

相关文章:

  • 实用指南:在 CentOS 中安装 MySQL
  • 卫星时间同步平台:助力分布式测控系统同步工作
  • C# Avalonia 15- Animation- Easing
  • CyberLink ColorDirector Ultra 2026 14.0.5712.0 视频后期调色
  • CF 1053 Div.2
  • haproxy负载均衡 - 详解
  • 豆油
  • linux shell awk 中括号 方括号 分割 []
  • 绩效面谈中的优质提问(一)
  • 从 “纸笔清单” 到全栈引擎:数据填报与类 Excel 控件如何重塑企业效率曲线 - 详解
  • 做题笔记总板
  • 嵌入式铁头山羊STM32-各章节详细笔记-查阅传送门 - 教程
  • 做题笔记6
  • 第17章 Day20-Day21 逆向爬虫之瑞数6
  • Vona ORM分表全攻略
  • 深入解析:设计模式-状态模式详解
  • 如何让百度快速收录网页如何让百度快捷收录网页的方法
  • 061_尚硅谷_算术运算符课堂练习
  • axi 4k边界检测
  • GOSIM 开源出海工作坊:给开源创业者的忠告
  • 一文搞懂Flex弹性布局空间分配规则
  • “小身材的大心脏”——HT-AD3PS-1+ 在成都恒利泰的射频江湖里到底做了什么?
  • AT_agc012_c [AGC012C] Tautonym Puzzle 题目分析
  • 详细介绍:回调函数与错误处理
  • .NET操作Word/WPS打造专业文档 - 页面设置与打印控制完全指南
  • NORDIC蓝牙6.0新品NRF54L15多协议超低功耗高性能BLE芯片 - 动能世纪
  • 快速入门HarmonyOS应用开发(三) - 教程
  • Docker + IDEA 一键部署! - 实践
  • Manim实现涟漪扩散特效
  • Xcode 26.0.1 (17A400) 发布 - Apple 平台 IDE