kafka集群搭建需要做的事情

首先,虚拟机克隆好之后的步骤如下:

1. 修改IP、主机名,关闭防火墙;(reboot重启)

2. 在/etc/hosts文件中进行IP与主机名的映射配置,集群中每天都记得配置;

3. 安装JDK并进行分发;进入/etc/profile.d/目录创建my_env.sh文件并在其中配置JAVA_HOME并进行分发;(分发jdk前先卸载自带的jdk);

4. 安装zookeeper并进行分发,具体为:

首先,在zookeeper根目录下创建zkData目录,并在该目录下创建myid文件进行编辑如下:

然后,执行如下命令进行分发,并修改myid文件:

rsync -av zookeeper root@centos103:/opt/software/

rsync -av zookeeper root@centos104:/opt/software/

最后,进入zookeeper/conf目录,复制zoo_sample.cfg文件并改名为zoo.cfg,修改如下配置:

dataDir=/opt/software/zookeeper/zkData

并增加如下配置:

server.2=centos102:2888:3888
server.3=centos103:2888:3888
server.4=centos104:2888:3888

再分发一下即可:

rsync -av zoo.cfg root@centos103:/opt/software/zookeeper/conf/

rsync -av zoo.cfg root@centos104:/opt/software/zookeeper/conf/

启动:

[root@centos102 zookeeper]# bin/zkServer.sh start
ZooKeeper JMX enabled by default
Using config: /opt/software/zookeeper/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED
[root@centos102 zookeeper]# jps
3334 QuorumPeerMain
3374 Jps
[root@centos102 zookeeper]# bin/zkServer.sh status conf/zoo.cfg

只有查看启动状态成功时,才算真正启动!!!

上面这个报错,百度弄个半天,关了防火墙也不行,最后也查看了日志文件,最后发现是/etc/hosts的映射文件只在centos102中配了,没有配另外两台。都配置好之后,就成功启动了。

5. kafka的安装、修改配置、启动

首先,进入kafka/config目录修改server.properties文件中的一些配置,具体修改如下:

#broker 的全局唯一编号,不能重复,只能是数字。
broker.id=0

#kafka 运行日志(数据)存放的路径,路径不需要提前创建,kafka 自动帮你创建,可以配置多个磁盘路径,路径与路径之间可以用","分隔
log.dirs=/opt/software/kafka/datas

#配置连接 Zookeeper 集群地址(在 zk 根目录下创建/kafka,方便管理)
zookeeper.connect=hadoop102:2181,hadoop103:2181,hadoop104:2181/kafka

集群中每个服务器都记得改,broker.id依次为0、1、2哦。

然后,执行启动命令时,报错如下:

启动命令:

[root@centos104 kafka]# bin/kafka-server-start.sh -daemon config/server.properties

百度查了发现,原来我安装的是src原本版本的kafka-3.0.0-src.tgz,重新安装正确的版本就好了。依次启动集群中的3台机器,再用命令jps检查启动的服务,发现启动成功了。

说明:KAFKA_HOME环境变量可配置,也可不配置,启动命令执行的位置有区别;但好像都得kafka目录下启动(?)。

#KAFKA_HOME
export KAFKA_HOME=/opt/software/kafka
export PATH=$PATH:$KAFKA_HOME/bin

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mfbz.cn/a/359145.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

基于Matlab无刷直流电机系统仿真建模的新方法

摘 要:在分析无刷直流电机(BLDC)数学模型的基础上,提出了无刷直流电机系统仿真建模的 新方法。在Matlab/Simulink 中,建立独立的功能模块,如BLDC 本体模块、电流滞环控制模块、 速度控制模块等,…

漏洞原理文件上传漏洞

一 文件上传漏洞介绍(理论) 文件上传漏洞是一种常见的web应用程序漏洞,允许攻击者向服务器上传恶意文件。这种漏洞可在没有恰当的安全措施的情况下,将任意类型的文件上传到服务器上,从而可能导致以下安全问题&#xff…

centos7安装mysql5.7 或者mysql8

1、centos7安装mysql8 mysql官网 https://dev.mysql.com/downloads/mysql/ 示例2个版本的下载地址 #5.7.30下载地址 wget https://cdn.mysql.com/archives/mysql-5.7/mysql-5.7.30-1.el7.x86_64.rpm-bundle.tar #8.0.22下载地址 wget https://cdn.mysql.com/archives/mysql-8…

响应式Web开发项目教程(HTML5+CSS3+Bootstrap)第2版 例5-5 Canvas 绘制三角形

代码 <!doctype html> <html> <head> <meta charset"utf-8"> <title>Canvas 绘制三角形</title> </head><body><canvas id"cavsElem">您的浏览器不支持Canvas&#xff0c;请升级浏览器</canvas…

03:华为云管理|云主机管理|云项目实战

华为云管理&#xff5c;云主机管理&#xff5c;云项目实战 安全组配置部署跳板机配置yum源&#xff0c;安装软件包优化系统服务安装配置ansible管理主机 模版镜像配置配置yum源&#xff0c;安装软件包优化系统 网站云平台部署实战华为云的负载均衡 安全组配置 设置安全组 云…

2分钟快速了解!全网最详细的性能测试教程之【Redis 简介和安装】

本篇文章主要介绍基于Redis的的简介和安装&#xff0c;其中参考了许多大佬写的文章&#xff0c;算是做一个Redis的基础教程吧。 Redis 简介 Redis 是完全开源的&#xff0c;遵守 BSD 协议&#xff0c;是一个高性能的 key-value 数据库。 Redis 与其他 key - value 缓存产品有…

AI嵌入式K210项目(24)-口罩检测

文章目录 前言一、实验准备二、实验过程三、实验结果总结 前言 本节课主要学习口罩检测功能&#xff0c;将摄像头采集的画面分析&#xff0c;比对模型&#xff0c;分析是否佩戴口罩&#xff0c;打印出佩戴口罩的状态 一、实验准备 请先将模型文件导入内存卡上&#xff0c;再…

【开源】SpringBoot框架开发天然气工程业务管理系统

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块三、使用角色3.1 施工人员3.2 管理员 四、数据库设计4.1 用户表4.2 分公司表4.3 角色表4.4 数据字典表4.5 工程项目表4.6 使用材料表4.7 使用材料领用表4.8 整体E-R图 五、系统展示六、核心代码6.1 查询工程项目6.2 工程物资…

AutoDL----VScode远程ssh连接

1、首先安装ssh插件 首先安装插件&#xff0c;在商店里抖索remote-ssh 2、建立连接 安装完成后在插件栏就会看到远程连接这一栏 点击添加后会让你输入ssh的地址&#xff0c;直接复制AutoDL的&#xff0c;按下Enter&#xff0c;选择第一个配置文件 选择Linux平台 继续后…

第九节HarmonyOS 常用基础组件19-CheckboxGroup

1、描述 多选框群组&#xff0c;用于控制多个选框全选或者全不选状态。 2、接口 CheckboxGroup(options?: {group?: string}) 3、参数 参数名 参数类型 必填 描述 group string 否 群组名称 4、属性 selectAll - boolean - 设置是否全选&#xff0c;默认值&…

springboot整合日志处理Logback

引言 ​ springboot框架 集成日志 logback 日志 ​ Logback是由log4j创始人设计的又一个开源日志组件。目前&#xff0c;logback分为三个模块&#xff1a;logback-core&#xff0c;logback-classic和logback-access。是对log4j日志展示进一步改进! 日志的级别 All < Trace…

CHS_04.2.3.3+互斥锁

CHS_04.2.3.3互斥锁 进程互斥&#xff1a;锁 接下来 用于实现互斥的一种方法 你可以简单理解为 锁就是一个bool的变量 进程互斥&#xff1a;锁 只有true和false或者零和一两种状态分别表示当前已上锁或者没有上锁 有这样的两个函数可以操作锁acquire 这个函数就是上锁获得 锁…

软硬兼施:亚信安慧AntDB创造更多可能性

亚信安慧AntDB是一种极具适配能力的数据库系统&#xff0c;它不仅在软件方面拥有出色的适应性&#xff0c;还能与国产硬件紧密配合&#xff0c;实现高效稳定的运行。无论是在上游还是下游领域&#xff0c;亚信安慧AntDB都展现出了卓越的适配程度。 在软件方面&#xff0c;亚信安…

防御保护常用知识

防火墙的主要职责在于&#xff1a;控制和防护 --- 安全策略 --- 防火墙可以根据安全策略来抓取流量之 后做出对应的动作 防火墙分类主要有四类&#xff1a; 防火墙吞吐量 --- 防火墙同一时间能处理的数据量多少 防火墙的发展主要经过以下阶段&#xff1b; 传统防火墙&#xf…

105.乐理基础-五线谱-谱号扩展

内容参考于&#xff1a;三分钟音乐社 上一个内容&#xff1a;104.乐理基础-五线谱-中音谱号、次中音谱号-CSDN博客 上一个内容里练习的答案&#xff1a; 首先高音谱号&#xff08;G谱号&#xff09;是从第二线开始画的&#xff0c;但是它只能从第二线开始画吗&#xff1f;并不…

nvm 工具使用介绍

目录 1.背景2.nvm介绍3.下载和安装4.配置环境变量5.配置淘宝镜像5.1 方式一:直接执行命令5.2 方式二:修改配置文件6.常用命令7.总结下载地址: https://github.com/coreybutler/nvm-windows/releases1.背景 在工作中,我们可能需要同时进行2个或者多个前端项目的开发,每个项…

软件行业门槛很低了吗

小编2003年开始搞了一家软件开发的小公司&#xff0c;那时候做点小的打卡考勤、消费、门禁一卡通软件都还能勉强生存。最红火的时候也有十多个员工。后来业务拓展越来越来了&#xff0c;公司慢慢也就没办法运转下去了。 后来只有转到一家建筑施工企业管弱电智能化版块&#xf…

行测-数量关系:4. 排列组合与概率问题、容斥原理问题

1、排列组合与概率问题 1.1 排列组合 1.1.1 基础概念 C 问法辨析 这些实际上是一种问题的不同问法。 例题 C C D A C&#xff0c;注意不能构成三角形的边长要去除。 1.1.2 经典题型 1.1.2.1 枚举法 2&#xff0c;从大到小&#xff0c;不重不漏 C B 1.1.2.2 捆绑法 48&#…

136832-63-8,活细胞示踪剂CMFDA(绿色),5-氯甲基荧光素二醋酸酯,广泛应用于细胞追踪和标记实验中

136832-63-8&#xff0c;活细胞示踪剂CMFDA(绿色)&#xff0c;5-氯甲基荧光素二醋酸酯&#xff0c;CellTracker Green CMFDA&#xff0c;可以用于基因表达分析等实验中&#xff0c;广泛应用于细胞追踪和标记实验中 您好&#xff0c;欢迎来到新研之家 文章关键词&#xff1a;1…

Spring AOP实现

Spring AOP实现 AOP概述什么是AOP什么是Spring AOP Spring AOP快速入门引入依赖实现计时器 Spring AOP详解Spring AOP核心概念切点(Pointcut)连接点(Join Point)通知(Advice)切面(Aspect) 通知类型注意事项 PointCut多个切面切面优先级 Order切点表达式execution表达式annotati…