ICode9

精准搜索请尝试: 精确搜索
首页 > 系统相关> 文章详细

linux 环境下,kafka_2.12-3.0.0 集群搭建

2022-06-16 16:35:24  阅读:247  来源: 互联网

标签:192.168 server 3.0 linux kafka root properties software


十年河东,十年河西,莫欺少年穷

学无止境,精益求精

卡夫卡优秀的消息队列,各大公司都在使用

1、准备三台虚拟机,分别为:192.168.182.128、192.168.182.129、192.168.182.130

2、下载kafka安装包,我使用的是3.2版本,https://kafka.apache.org/downloads

 3、讲kafka传入到三台liunx服务器,放在 /root/software/ 文件夹下

 4、解压压缩包

tar -xzvf kafka_2.12-3.0.0.tgz

5、重命名解压缩生成的文件夹名称

mv kafka_2.12-3.0.0 kafka

6、在kafka文件夹中新建logs 目录备用 

[root@localhost software]# cd kafka
[root@localhost kafka]# mkdir logs
 


 

 7、进入kafka 子文件夹config中,修改 server.properties 配置文件

[root@localhost kafka]# cd config
[root@localhost config]# ls
connect-console-sink.properties    connect-file-sink.properties    connect-mirror-maker.properties  kraft                server.properties       zookeeper.properties
connect-console-source.properties  connect-file-source.properties  connect-standalone.properties    log4j.properties     tools-log4j.properties
connect-distributed.properties     connect-log4j.properties        consumer.properties              producer.properties  trogdor.conf
[root@localhost config]# vim server.properties

分别将 192.168.182.128 服务器中的 server.properties 文件 配置项 broker.id 设置为 0,192.168.182.129 服务器中的 server.properties 文件 配置项 broker.id 设置为 1,192.168.182.130 服务器中的 server.properties 文件 配置项 broker.id 设置为 2

log.dirs 三台服务器均设置为  /root/software/kafka/logs  【logs就是第6步建的文件夹】

zookeeper.connect 三台服务器均设置为 192.168.182.128:2181,192.168.182.129:2181,192.168.182.130:2181 【代表kafka集群】

 wq保存

 

 9、三台服务器下配置kafka环境变量

vi /etc/profile

增加如下内容

export KAFKA_HOME=/root/software/kafka
export PATH=$PATH:$KAFKA_HOME/bin

 

 刷新配置文件

source /etc/profile

检测环境变量是否配置成功

[root@localhost bin]# echo $KAFKA_HOME
/root/software/kafka

10、启动kafka

kafka集群启动前要启动zookeeper集群 

然后三台服务器上执行

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

 三台服务器启动kafka

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

11、安装Jps插件,验证Kafak是否启动成功

我这里是才有yum来安装jdk的,方法如下:

yum install -y java-1.8.0-openjdk.x86_64

 

然后配置环境变量:

echo 'export JAVA_HOME=/usr/lib/jvm/jre
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/tools.jar' >> /etc/profile

重新加载配置

source /etc/profile

 

验证:

java -version

 

当我输入jps命令后,竟然报命令找不到?
错误原因:默认安装完只有运行环境,java安装目录下只有jre文件夹。

 

继续安装开发环境:

yum install java-1.8.0-openjdk-devel.x86_64

 

成功后再输入jps:

jps

 

 看到Kafka进程后,就证明咱们的KAFKA安装并启动成功了。

 

12、停止kafka时,和启动时正好相反,应先停止kafka,在停止zookeeper

停止kafka  【我使用的绝对路径】

/root/software/kafka/bin/kafka-server-stop.sh

停止zk

/root/software/kafka/bin/zookeeper-server-stop.sh

 

@天才卧龙的博客

标签:192.168,server,3.0,linux,kafka,root,properties,software
来源: https://www.cnblogs.com/chenwolong/p/kfk.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有