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

news/2025/9/25 16:22:33/文章来源:https://www.cnblogs.com/yxysuanfa/p/19111430

目录

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.mzph.cn/news/917218.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

国标GB28181公网直播EasyGBS如何构建全域覆盖的应急管理与安全生产解决方案?

在当今社会,安全生产和应急管理已经成为各行各业不可或缺的重要部分。全面提高安全生产管理水平、构建责任全覆盖、监管全过程、监管全方位的综合治理体系已成为社会发展的必然趋势。国标GB28181网页直播平台EasyGBS作…

Serilog.AspNetCore与Serilog的区别

一直以为用的是Serilog,深入了解后,用的是Serilog.AspNetCore,具体来了解下区别,与使用方法: Serilog 是“核心引擎”,只负责把日志事件生成出来; Serilog.AspNetCore 是“ASP.NET Core 专用适配器”,在 Seril…

基于MATLAB S函数实现多智能体间歇通信仿真

一、系统架构设计 1.1 通信模型 graph LR A[智能体1] -->|脉冲信号| B[智能体2] B -->|脉冲信号| C[智能体3] C -->|脉冲信号| A 1.2 核心模块通信触发模块:基于阈值事件的间歇通信 状态更新模块:离散时间一…

邢台做网站推广价格网站目标

新疆乌鲁木齐市2014-2015学年第二学期高一年级期末考试信息技术试卷(60分钟)第一部分必修模块(共80分)一、单项选择题(本大题共20小题,每小题2分,共40分)1.关于信息,以下说法不正确的是A.信息需要依附于载体而存在B&am…

北京如何申请公司网站备案号wordpress建站发文教程

电能质量在线监测装置 本办法对发电企业(包括分布式电源)、电网企业、用电企业的电能质量管理均有明确要求,要求在发电企业并网点、电网企业非线性设施、用电企业公共连接点设置电能质量监测装置,这会促进市场对电能质量在线监测…

个人网站备案需要哪些资料网站限时抢购怎么做

转自:https://zssure.blog.csdn.net/article/details/49231303 题记: DICOM医学图像处理专栏撰写已有两个年头,积累了近百篇文章。 起初 只是用于记录自己科研、工作中遇到的疑难问题,专注于图像处理(主要是医学图像…

C11中__atomic_thread_fence如何理解

C11 中的 atomic_thread_fence 函数是一种同步原语,用于在线程间强制执行内存排序约束。它为非原子操作和松弛原子操作建立内存同步顺序,而不执行实际的原子操作。这在多线程环境中尤其有用,可确保内存变化在不同线…

【光照】Unity中的[物理模型]PBR

【从UnityURP开始探索游戏渲染】专栏-直达PBR(Physically Based Rendendering)的核心内容与BRDF应用‌ PBR是一种基于物理光学原理的渲染框架,其核心是通过‌物理可测量的材质属性‌和‌真实的光照计算规则‌实现跨…

详细介绍:传输层————TCP

详细介绍:传输层————TCPpre { white-space: pre !important; word-wrap: normal !important; overflow-x: auto !important; display: block !important; font-family: "Consolas", "Monaco"…

c++内建函数

builtin 是内建的意思。下面函数的时间复杂度都是 \(O(1)\) 的。 __builtin_ctz(x) 返回末尾的 0 的个数(__builtin_ctz(0) 未定义)。 __builtin_popcount(x) 返回二进制下的 popcount。

门户网站开发解决方案福田公司门口

标题线性位置不变退化估计退化函数采用观察法估计退化函数采用试验法估计退化函数采用建模法估计退化函数运动模糊函数OpenCV Motion Blur在这一节中,得到的结果,有些不是很好,我需要再努力多找资料,重新完成学习,如果…

鹤山市城乡住房建设部网站照着别人网站做

题目描述 在数组中的两个数字,如果前面一个数字大于后面的数字,则这两个数字组成一个逆序对。输入一个数组,求出这个数组中的逆序对的总数P。并将P对1000000007取模的结果输出。 即输出P%1000000007 解题思路 剑指offer的解法 看到这个题目&#xff0…

comfyui-数字人

comfyui-数字人sonic。 1、安装sonic相关插件 模型 2-1 、 图 +音频 生成数字人口播 正面的清晰的照片 , sonic 会按音频的内容 识别 生成对应的视频 2-2 ,只有一张图, +文字的话。 先文字 生成音频 。 音频+图片…

我天,前端岗要消亡了吗?

大家好,我是R哥。 之前分享过一篇文章:前端岗、测试岗即将消亡!阿里菜鸟国际后端研发全员转全栈有的大厂靠成熟的低代码、测试平台,逐渐把前端、测试边缘化了,比如阿里菜鸟国际后端研发全员转全栈这个事,说明前端…

java8的集合新API - --

https://blog.csdn.net/m0_37989980/article/details/126091233

基于MATLAB/Simulink的500kW三相光伏逆变器仿真

一、系统架构设计 1.1 主电路拓扑 graph LR A[光伏阵列] -->|直流母线| B(DC-DC转换器) B -->|800V DC| C[三电平NPC逆变桥] C -->|LCL滤波器| D[380V电网] 1.2 核心模块组成DC-DC模块:Boost电路+MPPT控制 逆…

重庆seo整站优化设置网页游戏破解版

前言 在我们日常工作中,经常会遇到一些异常,比如:NullPointerException、NumberFormatException、ClassCastException等等。 那么问题来了,我们该如何处理异常,让代码变得更优雅呢? 1 不要忽略异常 不知…

做cps需要什么样的网站asp建站软件

跟数据类型是有关的。当你把一个普通的 JavaScript 对象传给 Vue 实例的 data 选项,Vue 将遍历此对象所有的属性,并使用 Object.defineProperty 把这些属性全部转为 getter/setter。但是不是所有的变动都可以通过set/get捕捉到,比如一个数组l…

Docker Compose启动多个镜像实例

1. Docker Compose 基础概念Docker Compose 是一个工具,用 YAML 文件定义和运行 多容器 Docker 应用。核心文件:docker-compose.yml通过一个命令可以启动、停止、管理整个应用,而不必一个一个容器操作。Compose 文件…

深入解析:⸢ 伍-Ⅱ⸥ ⤳ 默认安全治理实践:水平越权检测 前端安全防控

深入解析:⸢ 伍-Ⅱ⸥ ⤳ 默认安全治理实践:水平越权检测 & 前端安全防控pre { white-space: pre !important; word-wrap: normal !important; overflow-x: auto !important; display: block !important; font-fa…