在Debian系統上配置Kafka的關鍵步驟如下:
Kafka是用Scala和Java編寫的,因此需要先安裝Java運行環境。
sudo apt update
sudo apt install openjdk-8-jdk
安裝完成后,可以使用以下命令驗證Java是否安裝成功:
java -version
可以從Apache Kafka官網下載Kafka的安裝包,然后使用tar
命令解壓。
wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
tar -zvxf kafka_2.12-3.5.2.tgz
在環境變量中指定Kafka的安裝目錄以及命令文件所在目錄??梢栽?code>/etc/profile文件最下方添加如下兩行命令來配置全局環境變量:
export KAFKA_HOME=/path/to/kafka
export PATH=$PATH:$KAFKA_HOME/bin
然后,使配置生效:
source /etc/profile
在Kafka 2.8.0版本以后,引入了Kraft模式,可以不依賴外部Zookeeper運行。但如果需要使用Zookeeper,可以按照以下步驟進行配置和啟動:
wget https://downloads.apache.org/zookeeper/zookeeper-3.8.0/apache-zookeeper-3.8.0-bin.tar.gz
tar -zxvf apache-zookeeper-3.8.0-bin.tar.gz
export ZK_HOME=/path/to/zookeeper
export PATH=$PATH:$ZK_HOME/bin
在$ZK_HOME/conf/zoo.cfg
文件中配置Zookeeper的配置信息,然后啟動Zookeeper:
./bin/zkServer.sh start
進入Kafka的安裝目錄,然后啟動Kafka Broker:
cd /path/to/kafka
./bin/zookeeper-server-start.sh config/zookeeper.properties
./bin/kafka-server-start.sh config/server.properties
可以使用以下命令來驗證Kafka是否安裝成功:
./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
如果看到列出的topic,則表示Kafka安裝成功。
以上就是在Debian系統上配置Kafka的關鍵步驟。在配置過程中,還需要根據實際需求進行相應的調整和優化。