在Debian上安裝和配置Kafka涉及多個步驟,包括安裝必要的軟件包、配置Java運行環境、下載和解壓Kafka源碼、啟動Zookeeper和Kafka服務器等。以下是詳細的步驟:
Kafka需要Java運行時環境(JRE)或Java開發工具包(JDK)。你可以安裝OpenJDK:
sudo apt update
sudo apt install openjdk-11-jdk -y
驗證Java安裝:
java -version
從Apache Kafka官方網站下載最新版本的Kafka,并解壓到服務器上的目錄中。例如,下載Kafka 2.13-3.3.1版本:
wget https://downloads.apache.org/kafka/3.3.1/kafka_2.13-3.3.1.tgz
tar -xzf kafka_2.13-3.3.1.tgz
cd kafka_2.13-3.3.1
Kafka使用Zookeeper進行集群管理。首先啟動Zookeeper服務器:
bin/zookeeper-server-start.sh config/zookeeper.properties
在另一個終端窗口中,啟動Kafka服務器:
bin/kafka-server-start.sh config/server.properties
編輯Kafka的配置文件server.properties
,通常位于/opt/kafka/config/
目錄下。主要配置項包括:
broker.id
: 每個Kafka broker的唯一標識。listeners
: Kafka監聽的地址和端口。log.dirs
: Kafka日志存儲的目錄。使用以下命令檢查Zookeeper和Kafka服務是否正在運行:
sudo systemctl status zookeeper.service
sudo systemctl status kafka.service
使用netstat命令檢查Kafka是否在端口9092上監聽:
netstat -ntlp | grep 9092
以上步驟應該可以幫助你在Debian上成功安裝并運行Apache Kafka。