在Linux上安装Kafka的步骤如下:
一、安装JDK
- 下载JDK:
- 对于Ubuntu/Debian系统:
sudo apt install openjdk-8-jdk
- 对于CentOS/RedHat系统:
sudo yum install java-1.8.0-openjdk
- 验证安装:使用
java -version
命令确认JDK安装成功。
二、下载Kafka
- 下载Kafka安装包:
- 可以从Apache Kafka官网下载最新版本的Kafka。
- 例如,下载
kafka_2.12-3.5.2.tgz
。
- 解压安装包:
tar -zxvf kafka_2.12-3.5.2.tgz
三、配置环境变量
- 编辑环境变量文件:
- 例如,编辑
/etc/profile
文件,在文件末尾添加以下两行:
export KAFKA_HOME=/path/to/kafka export PATH=$PATH:$KAFKA_HOME/bin
- 加载环境变量:
source /etc/profile
四、启动Kafka服务器
- 进入Kafka目录:
cd $KAFKA_HOME
- 启动Kafka服务器:
./bin/kafka-server-start.sh config/server.properties
五、验证安装
- 检查Kafka是否正在运行:
netstat -an | grep 9092
六、配置Kafka集群(可选)
- 下载并解压Kafka Manager:
wget https://github.com/yahoo/CMAK/releases/download/3.0.0.5/cmak-3.0.0.5.zip unzip cmak-3.0.0.5.zip -d /data/ cd /data/cmak-3.0.0.5
- 配置Kafka Manager:
- 编辑
conf/application.conf
文件,设置Zookeeper地址和其他相关配置。
- 启动Kafka Manager:
./bin/cmak -java-home /usr/local/java/jdk-11.0.10 -Dconfig.file=./conf/application.conf -Dhttp.port=9000 &
请注意,以上步骤以Kafka 3.5.2版本为例,具体版本可能会有所不同。在安装前,请确保已经安装并配置好Zookeeper,因为Kafka需要Zookeeper来管理集群元数据。