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

统信UOS怎么安装和配置Kafka

夏雪大大_3377

夏雪大大_3377

发布时间:2026-07-05 06:41:47

|

875人浏览过

|

来源于php中文网

原创

在统信UOS系统上部署Kafka必须先解决Java环境缺失、ZooKeeper未启用、路径权限不足三大障碍;需安装OpenJDK 11并正确配置JAVA_HOME(arm64平台须用aarch64路径),下载kafka_2.13-3.6.0二进制包解压至/opt/kafka,显式设置zookeeper.dataDir=/var/lib/zookeeper及kafka的listeners、advertised.listeners和log.dirs,最后以-daemon方式先启ZooKeeper再启Kafka。

统信uos怎么安装和配置kafka

在统信UOS系统上部署Kafka消息队列,必须先解决Java环境缺失、ZooKeeper服务未启用、配置路径权限不足三大核心障碍,否则启动时会直接报错ClassNotFoundException或zookeeper not bound。

安装OpenJDK 11并配置JAVA_HOME

统信UOS默认不预装JDK,而Kafka 3.6.0+强制要求JDK 11运行环境,低于该版本将触发UnsupportedClassVersionError错误。

执行java -version检查当前Java状态,若提示“command not found”或输出版本号小于11,则必须安装。

运行sudo apt update && sudo apt install openjdk-11-jdk安装官方源提供的兼容包。

验证安装结果:输出中必须包含openjdk version "11.字样,否则说明安装失败或版本不对。

设置全局JAVA_HOME:echo 'export JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64' | sudo tee -a /etc/profile && source /etc/profile。注意路径中的amd64仅适用于x86_64架构;若为arm64设备(如飞腾/鲲鹏平台),需替换为aarch64,否则Kafka脚本无法识别JVM。

下载解压Kafka二进制包

使用Kafka官方推荐的Linux通用tar.gz包,避免选用未经UOS适配的高版本(如4.x),防止因glibc线程模型差异导致kafka-server-start.sh启动后立即退出。

创建标准部署目录:sudo mkdir -p /opt/kafka && sudo chown $USER:$USER /opt/kafka。

从阿里云镜像站下载经UOS验证的稳定版本:wget https://mirrors.aliyun.com/apache/kafka/3.6.0/kafka_2.13-3.6.0.tgz。

解压至目标目录并剥离顶层文件夹:tar -xzf kafka_2.13-3.6.0.tgz -C /opt/kafka --strip-components=1。

进入/opt/kafka目录,确认bin/、config/、libs/三个子目录存在且非空——缺少任一目录说明解压失败或包损坏。

启用内置ZooKeeper并配置数据路径

Kafka 3.6.0默认启用内置ZooKeeper,但UOS系统中若不显式配置dataDir,服务将默认写入/tmp,而UOS的systemd-tmpfiles定期清理/tmp会导致元数据丢失、集群不可用。

编辑ZooKeeper配置:nano /opt/kafka/config/zookeeper.properties。

找到dataDir行,将其修改为dataDir=/var/lib/zookeeper;该路径必须提前创建且赋予写权限:sudo mkdir -p /var/lib/zookeeper && sudo chown $USER:$USER /var/lib/zookeeper。

同时确认clientPort=2181未被注释,且端口未被其他进程占用(可用ss -tuln | grep :2181检查)。

【关键前提】必须确保/var/lib/zookeeper目录存在且当前用户有读写权限,否则ZooKeeper启动时静默失败,后续Kafka连接拒绝。

配置Kafka监听地址与日志路径

统信UOS环境下,Kafka默认配置的listeners=PLAINTEXT://:9092无法被外部访问,因为advertised.listeners未显式设置,会导致生产者/消费者连接超时或解析到localhost。

编辑/opt/kafka/config/server.properties:

① 设置唯一broker标识:broker.id=0(单机部署固定为0);

② 显式定义监听地址:listeners=PLAINTEXT://0.0.0.0:9092;

③ 必须同步配置对外广播地址:advertised.listeners=PLAINTEXT://$(hostname -I | awk '{print $1}'):9092——此处用命令替换获取本机实际IP,避免填localhost或127.0.0.1;

④ 修改日志存储路径:log.dirs=/var/lib/kafka-logs,然后执行sudo mkdir -p /var/lib/kafka-logs && sudo chown $USER:$USER /var/lib/kafka-logs;

⑤ 禁用ZooKeeper外连(启用内置):zookeeper.connect=localhost:2181保持默认即可,无需改成本地IP。

以daemon方式启动ZooKeeper和Kafka

必须严格按顺序启动:先ZooKeeper再Kafka,否则Kafka初始化时无法注册节点,报错“Connection refused”。

方法一:后台启动ZooKeeper服务:/opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties。

方法二:后台启动Kafka服务:/opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties。

验证ZooKeeper是否就绪:echo stat | nc localhost 2181 | grep Mode,输出含Mode: standalone即成功。

验证Kafka是否运行:jps | grep Kafka,看到Kafka进程名即表示服务已拉起。

相关文章

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

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

下载

相关标签:

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

热门AI工具

更多
DeepSeek

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

Atoms
Atoms Hot

Atoms是一款AI智能体工具,第一支自动构建真实业务的 AI 团队。

Laper
Laper Hot

Laper是专为编剧、导演和制片人推出的 AI 原生剧本创作工具。

Seko
Seko Hot

一款AI视频创作工具,主要用于商汤科技推出的创编一体的AI短视频创作Agent,适合需要提升相关任务效率的用户。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

豆包大模型

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

WorkBuddy

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

立刻MV
立刻MV Hot

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

相关专题

更多
kafka消费者组有什么作用
kafka消费者组有什么作用

kafka消费者组的作用:1、负载均衡;2、容错性;3、广播模式;4、灵活性;5、自动故障转移和领导者选举;6、动态扩展性;7、顺序保证;8、数据压缩;9、事务性支持。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2806

2024.01.12

kafka消费组的作用是什么
kafka消费组的作用是什么

kafka消费组的作用:1、负载均衡;2、容错性;3、灵活性;4、高可用性;5、扩展性;6、顺序保证;7、数据压缩;8、事务性支持。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

630

2024.02.23

rabbitmq和kafka有什么区别
rabbitmq和kafka有什么区别

rabbitmq和kafka的区别:1、语言与平台;2、消息传递模型;3、可靠性;4、性能与吞吐量;5、集群与负载均衡;6、消费模型;7、用途与场景;8、社区与生态系统;9、监控与管理;10、其他特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

604

2024.02.23

Java 流式处理与 Apache Kafka 实战
Java 流式处理与 Apache Kafka 实战

本专题专注讲解 Java 在流式数据处理与消息队列系统中的应用,系统讲解 Apache Kafka 的基础概念、生产者与消费者模型、Kafka Streams 与 KSQL 流式处理框架、实时数据分析与监控,结合实际业务场景,帮助开发者构建 高吞吐量、低延迟的实时数据流管道,实现高效的数据流转与处理。

670

2026.02.04

Playwright 测试失败怎么办
Playwright 测试失败怎么办

Playwright测试失败专题汇集超时、定位器匹配、浏览器提前关闭、依赖与插件配置、文件上传、SSL及Docker启动等故障文章,并介绍通过截图、报告和Trace定位错误。

0

2026.10.21

Playwright 页面操作指南
Playwright 页面操作指南

Playwright页面操作专题汇集元素定位、点击与输入、等待响应、多页面切换、Iframe、事件监听及文件处理的已审核文章,便于按操作场景查阅示例与常见问题。

0

2026.10.21

Playwright 入门教程
Playwright 入门教程

Playwright入门专题汇集测试框架安装、VS Code配置、录制脚本、编写首个用例、运行调试及查看报告的已审核文章,帮助初学者搭建端到端测试流程。

0

2026.10.21

OpenJDK JVM参数怎么调优
OpenJDK JVM参数怎么调优

Java应用运行缓慢,如何调整JVM参数?本专题介绍OpenJDK JVM性能调优的基本流程,涵盖性能指标确认、运行数据采集、内存配置和垃圾回收分析,帮助你先定位瓶颈,再通过对照测试验证效果,避免直接套用参数而影响应用稳定性。

100

2026.10.16

OpenJDK怎么配置Java开发环境
OpenJDK怎么配置Java开发环境

怎样用OpenJDK搭建开发环境?本专题介绍版本选择、下载安装、环境变量配置和编译运行验证,帮助你理清JDK的作用及基本配置流程,并通过简单程序检查环境是否可用,为后续项目开发做好准备。

80

2026.10.16

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Apache Storm教程手册
Apache Storm教程手册

共11课时 | 15.2万人学习

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

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