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

大数据集群架构hadoop集群、Hbase集群、zookeeper、kafka、spark、flink、doris、dataease(四)

kafka单节点部署

wget -c  https://dlcdn.apache.org/kafka/3.7.2/kafka_2.13-3.7.2.tgz

tar -xf kafka_2.13-3.7.2.tgz -C /data/   &&  mv /data/kafka_2.13-3.7.2/ /data/kafka

首先部署jdk1.8版本,大于1.8可能会出现很多bug所有机器都装

wget -c https://download.java.net/openjdk/jdk8u44/ri/openjdk-8u44-linux-x64.tar.gz

tar xf openjdk-8u44-linux-x64.tar.gz   -C /data

mv /data/java-se-8u44-ri/ /data/java

echo '

JAVA_HOME=/data/java

PATH=$JAVA_HOME/bin:$PATH

export JAVA_HOME PATH

export KAFKA_HOME=/data/kafka

export PATH=$PATH:$KAFKA_HOME/bin

' >> /etc/profile 

source /etc/profile

java -version

vim /data/kafka/config/server.properties    修改配置文件

log.dirs=/data/kafka/logs    #日志目录

zookeeper.connect=192.168.81.128:2181   #zk的实际地址

listeners=PLAINTEXT://0.0.0.0:9092  #Kafka 接受来自所有 IP 地址的连接。

advertised.listeners=PLAINTEXT://172.17.44.179:9092   #Kafka 对外公开的连接地址

mkdir /data/kafka/logs

启动命令   kafka-server-start.sh  /data/kafka/config/server.properties  &

http://www.xdnf.cn/news/14535.html

相关文章:

  • Oracle 逻辑结构与性能优化(上)
  • Softhub软件下载站实战开发(三):平台管理模块实战
  • 第9章:Neo4j集群与高可用性
  • SpringBoot学习day3-SpringBoot注解开发(新闻项目后段基础)
  • Java中的CAS与ABA
  • Leetcode 刷题记录 14 —— 回溯
  • 什么是装饰器?
  • UE5错误 Linux离线状态下错误 circular dependency detected;includes/requires
  • chapter06-针对分类的微调
  • 实战指南:部署MinerU多模态文档解析API与Dify深度集成(实现解析PDF/JPG/PNG)
  • 【RAG文档解析】深度剖析 PDF 解析的痛点与方案
  • springboot集成dubbo
  • LangChain调用本地modelscope下载的Deepseek大模型
  • Python打卡第54天
  • 13分钟讲解主流Linux发行版
  • origin绘制双Y轴柱状图、双Y轴柱状点线图和双Y轴点线图
  • Node.js验证码:从生成到验证的趣味之旅
  • 条件收敛的级数中项必须趋于 0,正负项抵消,但趋于 0 的速度不需要“足够快”
  • 【学习笔记】深入理解Java虚拟机学习笔记——第9章 类加载及执行子系统的案例与实战
  • 深度学习进化史:从神经元的诞生到万亿参数的觉醒
  • 掌握这些 Python 函数,让你的代码更简洁优雅
  • Git基本使用
  • npm install报错
  • Hudi 与 Hive 集成
  • https说明
  • RV1126+OPENCV对视频流单独进行视频膨胀/腐蚀操作
  • Spring AI 项目实战(八):Spring Boot + AI + DeepSeek 打造企业级智能文档分类系统
  • 40套精品大气黑金系列行业PPT模版分享
  • Web后端基础:数据库
  • 【JavaScript-Day 42】深入解析事件冒泡与捕获:掌握事件委托的精髓