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的情况,都是环境没有支持的原因,配置响应的环境即可执行。