Centos7系统配置Kafka

京漂大叔 2020-12-17 AM 4867℃ 0条

pexels-photo-276218.jpeg
Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者在网站中的所有动作流数据。

本来使用RibbitMQ,但咨询了一个前辈,说RibbitMQ比较复杂,Kafka简单,而且处理的数据量也比RibbitMQ大。所以就放弃RibbitMQ,使用Kafka来搭建消息队列服务。

Kafka需要java环境支持,所以先配置JDK环境。
一、安装JDK 1.8

1、使用yum命令安装

yum install java-1.8.0-openjdk* -y

2、检查是否安装成功

java -version

3、jdk默认安装在/usr/lib/jvm,在etc/profile中添加环境变量

export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.181-3.b13.el7_5.x86_64 
export JRE_HOME=$JAVA_HOME/jre 
export CLASSPATH=.:$JAVA_HOME/lib:$JRE_HOME/lib:$CLASSPATH 
export PATH=.:$JAVA_HOME/bin:$JRE_HOME/bin:$KE_HOME/bin:${MAVEN_HOME}/bin:$PATH

4、刷新文件

source  /etc/profile

二、配置完java环境之后,开始安装Kafka,从Kafka官网下载安装包,我下载的是这个kafka_2.13-2.6.0.tgz,运行Kafka需要使用ZooKeeper,所以需要先启动ZooKeeper,现在的Kafka安装包自带了ZooKeeper,可以很好的和当前版本兼容。当然,你可以单独下载ZooKeeper,自行配置启动
1、解压Kafka压缩包,进入Kafka目录,执行下面的命令,启动ZooKeeper。

bin/zookeeper-server-start.sh config/zookeeper.properties

2、执行下面的命令启动Kafka.

bin/kafka-server-start.sh config/server.properties &

3、这样Kafka就配置,启动成功了,是不是很简单。然后就是创建主题,发送消息,订阅消息,以及设置broker集群和ZooKeeper集群分布式了。

备注,如何在安装过程中,遇到命令无法执行,file not found的情况,都是环境没有支持的原因,配置响应的环境即可执行。

标签: Kafka, Zookeeper, JDK1.8, RibbitMQ

非特殊说明,文章均为原创。

评论啦~