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.hqwc.cn/news/440306.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

力扣题目训练(5)

2024年1月29日力扣题目训练 2024年1月29日力扣题目训练345. 反转字符串中的元音字母349. 两个数组的交集350. 两个数组的交集 II96. 不同的二叉搜索树97. 交错字符串44. 通配符匹配 2024年1月29日力扣题目训练 2024年1月29日第五天编程训练,今天主要是进行一些题训…

用友GRP-U8 forgetPassword_old.jsp SQL注入漏洞(QVD-2023-31085)

0x01 产品简介 用友GRP-U8R10行政事业内控管理软件是用友公司专注于国家电子政务事业,基于云计算技术所推出的新一代产品,是我国行政事业财务领域最专业的政府财务管理软件。 0x02 漏洞概述 用友GRP-U8R10行政事业内控管理软件 forgetPassword_old.jsp接口处存在SQL注入漏…

移动机器人正引领着高端芯片实现量产

在数字化时代,高端芯片已经成为推动各行各业创新发展的关键要素。而随着移动机器人技术的不断突破,高端芯片的量产也迎来了新的发展机遇。在这个过程中,移动机器人不仅为高端芯片提供了广阔的应用场景,还为其实现量产提供了强有力…

【Go】Viper读取配置文件

go get github.com/spf13/viper 1. 设置配置文件的信息 etcd:ip: "192.168.6.106"port: 2379dialTimeout: 3redis:ip: "192.168.6.107"port: 6379password: "root1028"2. 读取配置文件的信息 2.1 通过kv的方式 package mainimport ("fm…

【蓝桥杯日记】复盘篇二:分支结构

前言 本篇笔记主要进行复盘的内容是分支结构,通过学习分支结构从而更好巩固之前所学的内容。 目录 前言 目录 🍊1.数的性质 分析: 知识点: 🍅2.闰年判断 说明/提示 分析: 知识点: &am…

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

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

基于JAVA+SpringBoot+Vue的前后端分离的美食分享推荐平台2

✌全网粉丝20W,csdn特邀作者、博客专家、CSDN新星计划导师、java领域优质创作者,博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ 🍅文末获取项目下载方式🍅 一、项目背景介绍: 在当今社会&#xff0…

Python爬虫实践指南:利用cpr库爬取技巧

引言 在信息时代,数据是无价之宝。为了获取网络上的丰富数据,网络爬虫成为了不可或缺的工具。在Python这个强大的编程语言中,cpr库崭露头角,为网络爬虫提供了便捷而高效的解决方案。本文将深入探讨如何利用cpr库实现数据爬取的各…

【SpringBoot】springboot整合mongoDB

目录 1.配置 2.使用 创建实体类 创建MongoDB仓库接口 创建一个控制器 1.配置 创建好springboot工程后 引入mongoDB依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongo…

【MySQL 流浪之旅】 第六讲 浅谈 MySQL 锁

系列文章目录 【MySQL 流浪之旅】 第一讲 MySQL 安装【MySQL 流浪之旅】 第二讲 MySQL 基础操作【MySQL 流浪之旅】 第三讲 MySQL 基本工具【MySQL 流浪之旅】 第四讲 MySQL 逻辑备份【MySQL 流浪之旅】 第五讲 数据库设计的三个范式 目录 系列文章目录 一、什么是锁&#x…

25考研北大软微该怎么做?

25考研想准备北大软微&#xff0c;那肯定要认真准备了 考软微需要多少实力 现在的软微已经不是以前的软微了&#xff0c;基本上所有考计算机的同学都知道&#xff0c;已经没有什么信息优势了&#xff0c;只有实打实的有实力的选手才建议报考。 因为软微的专业课也是11408&am…

D1675滤波器和缓冲器用于单通道6阶高清视频滤波驱动电路,可提高视频信号性能

D1675单电源工作电压为2.5V到5V&#xff0c;是一款高清视频信号译码、编码的滤波器和缓冲器。与使用分立元件的传统设计相比&#xff0c;D1675更能节省PCB板面积&#xff0c;并降低成本以及提高视频信号性能。D1675集成了一个直流耦合输入缓冲器、一个消除带外噪声的视频编码器…