centos 8 安装 kafka

一. 安装 java

因为是在本地虚拟机测试, 所以 先更新了 yum 中系统软件包列表,确保所需软件可用:

sudo yum update

然后,再安装 OpenJDK8:

sudo yum install java-1.8.0-openjdk-devel

安装完成后执行 java -version, 验证是否安装成功:

[root@localhost ~]# java -version
openjdk version "1.8.0_312"
OpenJDK Runtime Environment (build 1.8.0_312-b07)
OpenJDK 64-Bit Server VM (build 25.312-b07, mixed mode)

二. 配置 JAVA 环境变量

编辑 profile 文件:

sudo vi /etc/profile

在末尾加上(替换为你的jdk版本号):

export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-<version>
export PATH=$PATH:$JAVA_HOME/bin

执行 source /ect/profile 使配置生效.

输入 echo $JAVA_HOME 验证变量是否正确设置:

[root@localhost ~]# echo $JAVA_HOME
/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.312.b07-2.el8_5.x86_64

三, 验证 java 是否正确安装:

输入 java -version :

[root@localhost ~]# java -version
openjdk version "1.8.0_312"
OpenJDK Runtime Environment (build 1.8.0_312-b07)
OpenJDK 64-Bit Server VM (build 25.312-b07, mixed mode)

四. 安装 Zookeeper

从官网下载Zookeeper:

wget https://dlcdn.apache.org/zookeeper/zookeeper-3.9.1/apache-zookeeper-3.9.1-bin.tar.gz

解压 && 重命名:

tar -zxvf apache-zookeeper-3.9.1-bin.tar.gz
mv apache-zookeeper-3.9.1-bin zookeeper

配置:

cd zookeeper/conf
mv zoo_sample.cfg zoo.cfg

运行 bin 目录下的 zkServer.sh:

~/zookeeper/bin/zkServer.sh start  // stop 就是关闭

成功启动:

[root@localhost bin]# ./zkServer.sh start
/usr/bin/java
ZooKeeper JMX enabled by default
Using config: /www/server/zookeeper/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED

运行 jps 命令(启动成功如下图):

[root@localhost bin]# jps
544346 QuorumPeerMain
544403 Jps

五. 安装 kafka

从官网下载kafka :

wget https://downloads.apache.org/kafka/3.6.0/kafka_2.12-3.6.0.tgz

解压 && 重命名:

tar -zxvf kafka_2.12-3.6.0.tgz
mv kafka_2.12-3.6.0 kafka

配置:

cd kafak/config
vim server.properties

配置信息如下:

port=9092
# 内网ip
host.name=10.125.0.25
# 外网ip
advertised.host.name=119.55.65.157

在本地虚拟机只需要:

port=9092
host.name=192.168.50.150

如果需要配置集群, 配置中的 broker.id 的值需要不一样.

启动 kafka(-daemon 表示后台启动):

~/kafka/bin/kafka-server-start.sh -daemon config/server.properties

jps 查看是否启动成功(下图有kafka表示成功):

[root@localhost kafka]# jps
546968 Jps
544346 QuorumPeerMain
546869 Kafka

关闭 kafka:

~/kafka/bin/kafka-server-stop.sh

六 . 可视化 管理 kafka:

可以安装 kafka-manager 管理

sbt安装