Kafka安装

发布时间 2023-06-15 15:32:13作者: 小肚腩吖

环境说明

在安装Kafka之前,请确保已经安装了JDK和Zookeeper。运行Kafka,首先保证Java环境能正常使用,可执java -version查看。

安装JDK环境

  1. 下载jdk安装包
curl https://download.oracle.com/java/20/latest/jdk-20_linux-x64_bin.tar.gz -o jdk-20_linux-x64_bin.tar.gz
  1. 新建JDK安装环境,并把JDK软件包移到新安装位置
 mkdir /usr/java
 mv jdk-20_linux-x64_bin.tar.gz /usr/java/
  1. 解压缩
 cd /usr/java/
 tar -zxvf jdk-20_linux-x64_bin.tar.gz 
  1. 配置Java环境变量,添加以下内容到/etc/profile文件中
#JAVA
export JAVA_HOME=/usr/java/jdk-20.0.1
export CLASSPATH=.:JAVA_HOME/jre/lib/rt.jar:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export PATH=$PATH:$JAVA_HOME/bin
  1. 使环境变量生效
source /etc/profile
  1. 查看Java安装版本
java -version

img

解压并安装zookeeper

  1. 下载zookeeper
curl https://archive.apache.org/dist/zookeeper/zookeeper-3.8.1/apache-zookeeper-3.8.1.tar.gz -o apache-zookeeper-3.8.1.tar.gz
  1. 创建一个Kafka文件夹,把Zookeeper解压此目录并查看
 mkdir /home/kafka
 tar -zxvf apache-zookeeper-3.8.1.tar.gz -C /home/kafka/

img
3. 创建目录环境

mkdir -p /home/kafka/apache-zookeeper-3.8.1/data
  1. 修改配置文件

dataDir:zookeeper的数据目录
cllientPort:zookeeper客户端连接端口
server.num:zookeeper的集群地址。其中num是数字,对应的每个节点的myid。
值是IP地址:集群内机器通讯使用(Leader监听此端口):选举leader端口(所有节点都有此端口)

# 复制配置文件
egrep -v "^$|^#" /home/kafka/apache-zookeeper-3.8.1/conf/zoo_sample.cfg > /home/kafka/apache-zookeeper-3.8.1/conf/zoo.cfg  
# 配置zoo.cfg文件,将以下内容加入到文件中
tickTime=2000
initLimit=10
syncLimit=5
dataDir=/home/kafka/apache-zookeeper-3.8.1/data
clientPort=2181
server.1=192.168.17.129:2888:3888
server.2=192.168.17.130:2888:3888
server.3=192.168.17.131:2888:3888                           
  1. 分别在三台主机中分别配置myid
# 192.168.17.129 主机
echo 1 > /home/kafka/apache-zookeeper-3.8.1/data/myid
# 192.168.17.130 主机
echo 2 > /home/kafka/apache-zookeeper-3.8.1/data/myid
# 192.168.17.131 主机
echo 3 > /home/kafka/apache-zookeeper-3.8.1/data/myid
  1. 启动服务
cd /home/kafka/apache-zookeeper-3.8.1/bin/ && ./zkServer.sh start