Kafka集群搭建

server/2024/10/19 5:29:50/

Kafka集群搭建

  1. 将master节点的/data目录下的Kafka安装包解压到/opt/software目录下

    tar -zxvf kafka_2.12-2.4.1.tgz -C /opt/software/
    mv kafka_2.12-2.4.1 kafka
    
  2. 进入Kafka安装目录的config目录修改server.properties配置文件,将“broker.id”改为“0”,“log.dirs”改为“/opt/logs/kafka-logs”,“zookeeper.connect”改为“master:2181,slave1:2181,slave2:2181”

    cd /opt/software/kafka/config
    
    参数名参数值
    broker.id0
    log.dirs/opt/logs/kafka-logs
    zookeeper.connectmaster:2181,slave1:2181,slave2:2181
    参数名参数值
    broker.id1
    log.dirs/opt/logs/kafka-logs
    zookeeper.connectmaster:2181,slave1:2181,slave2:2181
    参数名参数值
    broker.id2
    log.dirs/opt/logs/kafka-logs
    zookeeper.connectmaster:2181,slave1:2181,slave2:2181
  3. 将master节点配置好的Kafka文件远程发送至slave1、slave2节点相同目录下,并将slave1、slave2节点的server.properties配置文件中的broker.id分别修改为1、2。

    scp -r kafka slave1:$pwd
    scp -r kafka slave2:$pwd
    
  4. 在master节点的/etc/profile文件中配置Kafka环境变量KAFKA_HOME和PATH的值,并使配置文件立即生效。再将master节点配置好的/etc/profile文件远程发送至slave1、slave2节点,同样使配置文件立即生效

    vi /etc/profileexport KAFKA_HOME=/root/software/kafka
    export PATH=$PATH:$KAFKA/binscoure /etc/profilescp /etc/profile slave1:/etc/
    scp /etc/profile slave2:/etc/
    
  5. 分别在各节点启动ZooKeeper集群,确保ZooKeeper集群启动后再在各节点启动Kafka集群,并查看各节点进程

    
    

http://www.ppmy.cn/server/28666.html

相关文章

每天学习一个Linux命令之sed

每天学习一个Linux命令之sed 欢迎来到我的博客系列,今天我们将学习一个非常强大的Linux命令——sed,它可以在文本处理中实现各种强大的操作。sed(Stream Editor)是Linux环境下的一种流编辑器,可以对文件内容进行替换、…

机器学习之K-medians聚类

K-medians聚类是一种聚类算法,类似于K-means,但是它使用中位数来确定簇的中心,而不是平均值。这种方法在处理数据中存在离群值或异常值时比较有用,因为中位数对离群值不敏感。K-medians的步骤与K-means类似,但在每次迭代中,它使用中位数来更新簇的中心。 K-medians的算法…

SCI一区 | MFO-CNN-LSTM-Mutilhead-Attention多变量时间序列预测(Matlab)

SCI一区 | MFO-CNN-LSTM-Mutilhead-Attention多变量时间序列预测(Matlab) 目录 SCI一区 | MFO-CNN-LSTM-Mutilhead-Attention多变量时间序列预测(Matlab)预测效果基本介绍程序设计参考资料 预测效果 基本介绍 1.Matlab实现MFO-CNN…

CyclicBarrier

循环栅栏,用来进行线程协作,等待线程满足某个计数。构造时设置『计数个数』,每个线程执行到某个需要“同步”的时刻调用 await() 方法进行等待,当等待的线程数满足『计数个数』时,继续执行 ExecutorService service …

IDEA基于Maven构建项目

IDEA基于Maven构建项目 一、Maven简介 Apache Maven 是一个软件项目管理和理解工具。基于项目对象模型的概念(POM),Maven 可以从中心信息中管理项目的构建、报告和文档。 Apache Maven 可以用于构建和管理任何基于 Java 的项目。 下载地址…

【实时数仓架构】方法论

笔者不是专业的实时数仓架构,这是笔者从其他人经验和网上资料整理而来,仅供参考。写此文章意义,加深对实时数仓理解。 一、实时数仓架构技术演进 1.1 四种架构演进 1)离线大数据架构 一种批处理离线数据分析架构,…

OpenAI发布GPT-4.0使用指南

大家好,ChatGPT 自诞生以来,凭借划时代的创新,被无数人一举送上生成式 AI 的神坛。在使用时,总是期望它能准确理解我们的意图,却时常发现其回答或创作并非百分之百贴合期待。这种落差可能源于我们对于模型性能的过高期…

Springboot 的Bean对象找不到问题

看红色的字体显示: Controller需要Service这个Bean对象 解决方式: Service类忘记写实现了