讲师中心 微信公众号
AI工具推荐 视频效率加速

Linux 中怎么安装配置 Kafka 消息队列

星丽小哥_8507

星丽小哥_8507

发布时间:2026-10-15 10:18:34

|

700人浏览过

|

来源于php中文网

原创

Linux安装Kafka核心是先装JDK(如17),再下载解压Kafka,依版本选ZooKeeper或KRaft模式配置:关键设对listeners(监听)和advertised.listeners(客户端连接地址),最后启动验证。

linux 中怎么安装配置 kafka 消息队列

Linux 中安装配置 Kafka,核心是先装好 Java,再部署 Kafka 本体,并正确设置监听地址和元数据协调服务(ZooKeeper 或 KRaft)。关键不在“能不能装”,而在“配得对不对”——尤其是云服务器或跨网段访问时,listeners 和 advertised.listeners 必须区分清楚。

确认并安装 Java 环境

Kafka 是 Java 应用,必须有 JDK 支持:

  • 检查是否已安装:java -version。输出应含 1.8、11、17 或更高版本(Kafka 3.3+ 推荐 JDK 17)
  • 若未安装:
    • Ubuntu/Debian:sudo apt install openjdk-17-jdk
    • CentOS/Rocky:sudo dnf install java-17-openjdk-devel
    • 手动解压 JDK(如 jdk-17.0.8)后,需配置 JAVA_HOME 并加入 PATH,最后运行 source /etc/profile

下载并解压 Kafka

推荐使用官方二进制包(无需编译),注意 Scala 版本匹配(如 kafka_2.12-3.9.1.tgz 表示 Scala 2.12):

Zynq Linux Hardware Debug
Zynq Linux Hardware Debug

Zynq‑7000 / Zynq UltraScale+ 硬件调试技能。适用于 Xilinx Zynq(Cortex‑A9/A53 + FPGA)Linux 环境,调试 I2C、I2S、UART、GPIO 等外设。包括设备树配置、内核驱动、用户空间调试工具、交叉编译和常见问题排查,支持 PetaLinux 开发。

下载
  • 进入 /opt 目录:cd /opt
  • 下载(以 Kafka 3.9.1 为例):sudo curl -fsSLo kafka.tgz https://downloads.apache.org/kafka/3.9.1/kafka_2.12-3.9.1.tgz
  • 解压并重命名:sudo tar -xzf kafka.tgz && sudo mv kafka_2.12-3.9.1 kafka
  • 建议创建专用用户运行(更安全):sudo useradd -r -d /opt/kafka -s /usr/sbin/nologin kafka,再改属主:sudo chown -R kafka:kafka /opt/kafka

选择协调模式并配置 Kafka

有两种主流方式,选其一即可:

  • ZooKeeper 模式(兼容老版本,适合 Kafka ≤ 3.2):
    • 使用 Kafka 自带 ZooKeeper(开发/测试够用):/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties
    • 编辑 /opt/kafka/config/server.properties,重点修改:
      • broker.id=0(单机填 0;集群每台唯一)
      • listeners=PLAINTEXT://0.0.0.0:9092(监听所有网卡)
      • advertised.listeners=PLAINTEXT://你的公网IP或内网IP:9092(客户端连接用的地址)
      • zookeeper.connect=localhost:2181(若 ZooKeeper 在同机)
  • KRaft 模式(Kafka ≥ 3.3,无 ZooKeeper,推荐新部署):
    • 删除旧 ZooKeeper 配置,启用内置共识:rm -f /opt/kafka/config/zookeeper.properties
    • 编辑 /opt/kafka/config/kraft/server.properties:
      • process.roles=broker,controller
      • node.id=1(集群中每台编号不同)
      • controller.quorum.voters=1@your-ip1:9093,2@your-ip2:9093,3@your-ip3:9093
      • listeners=PLAINTEXT://0.0.0.0:9092,CONTROLLER://0.0.0.0:9093
      • advertised.listeners=PLAINTEXT://your-public-ip:9092
    • 首次启动前需格式化存储目录:/opt/kafka/bin/kafka-storage.sh format -t $(/opt/kafka/bin/kafka-storage.sh random-uuid) -c /opt/kafka/config/kraft/server.properties

启动与验证

启动后务必验证连通性,尤其云服务器要检查防火墙:

  • 启动 Kafka(KRaft 模式):sudo -u kafka /opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/kraft/server.properties
  • 启动 Kafka(ZooKeeper 模式):sudo -u kafka /opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties
  • 检查进程:ps aux | grep kafka 或 jps | grep Kafka
  • 开放端口(如用 firewalld):sudo firewall-cmd --add-port=9092/tcp --permanent && sudo firewall-cmd --reload
  • 快速测试(创建 topic 并收发):
    • /opt/kafka/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
    • 新开终端启动消费者:/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
    • 再开终端启动生产者:/opt/kafka/bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test,输入文字回车即发送

相关文章

Kafka Eagle可视化工具
Kafka Eagle可视化工具

Kafka Eagle是一款结合了目前大数据Kafka监控工具的特点,重新研发的一块开源免费的Kafka集群优秀的监控工具。它可以非常方便的监控生产环境中的offset、lag变化、partition分布、owner等,有需要的小伙伴快来保存下载体验吧!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

Lovart
Lovart Hot

一款面向视觉设计创作的AI设计平台,可通过智能体和画布工作流辅助制作海报、Logo、网页、PPT及其他视觉内容。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

相关专题

更多
服务器是什么
服务器是什么

服务器是一种计算机硬件设备或软件程序,它具有强大的计算和存储能力,用请求、存储数据和提供服务。它在互联网中着关重要的作用,为用户提供各种服务和资源。本专题为大家提供服务器相关的文章、下载、课程内容,供大家免费下载体验。

437

2023.08.15

连接apple id服务器时出错
连接apple id服务器时出错

连接apple id服务器时出错的原因包括网络连接问题、服务器问题、Apple ID账户问题、设备问题、防火墙或安全软件问题、时间和日期设置问题、Apple服务器维护等。本专题为大家提供apple id相关的文章、下载、课程内容,供大家免费下载体验。

920

2023.09.08

搭建互联网服务器
搭建互联网服务器

搭建互联网服务器需要:1、选择合适的硬件和操作系统,第一步是选择合适的硬件和操作系统;2、安装和配置操作系统,是搭建互联网服务器的关键步骤;3、安装和配置服务器软件,是搭建互联网服务器的下一步,常见的服务器软件包括Apache、Nginx、Tomcat等;4、配置防火墙和安全性,是搭建互联网服务器的重要步骤;5、域名解析和配置,是搭建互联网服务器的最后一步。

2892

2023.09.19

如何查看服务器状态
如何查看服务器状态

查看服务器状态的方法有使用命令行工具、图形界面工具、监控工具、日志文件和远程管理工具等。本专题为大家提供服务器状态相关的文章、下载、课程内容,供大家免费下载体验。

976

2023.10.09

服务器域名转接慢怎么解决
服务器域名转接慢怎么解决

服务器域名转接慢的解决办法有DNS优化、服务器优化、CDN加速、前端优化和网络优化等。本专题为大家提供服务器相关的文章、下载、课程内容,供大家免费下载体验。

869

2023.10.17

服务器评测软件
服务器评测软件

服务器评测软件有PassMark Software、CPU-Z、GPU-Z、CrystalDiskMark、IOmeter、JMeter、LoadRunner、Apache Bench等等。详细介绍:1、PassMark Software是一款综合性的服务器性能测试软件,可以评估服务器在各种负载条件下的性能;2、CPU-Z是一款可以提供服务器CPU详细信息的软件等等。

434

2023.10.17

如何开启TFTP服务器
如何开启TFTP服务器

开启TFTP服务器的步骤包括选择TFTP服务器软件、下载和安装软件、配置TFTP服务器以及启动和测试服务器等。本专题为大家提供服务器相关的文章、下载、课程内容,供大家免费下载体验。

2636

2023.10.18

服务器负载不兼容怎么解决
服务器负载不兼容怎么解决

解决方法:1、增加服务器资源;2、负载均衡;3、优化应用程序;4、增加缓存机制;5、分布式架构;6、限流和熔断;7、自动化扩容。想知道更详细服务器负载不兼容的解决方法,可以访问本专题下面的文章。

4892

2023.10.20

剧云AI短剧创作教程合集
剧云AI短剧创作教程合集

本专题聚焦剧云AI短剧创作,讲解从短剧灵感、梗概、全局大纲到分集、分场和正文的完整流程及节奏设计方法。

0

2026.10.14

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Python uv官方安装与入门文档
Python uv官方安装与入门文档

共0课时 | 0人学习

Buffalo框架快速入门指南
Buffalo框架快速入门指南

共0课时 | 0人学习

Valgrind支持平台说明
Valgrind支持平台说明

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn