在Debian上配置Kafka的步驟如下:
首先,需要安裝Java運行環境,因為Kafka是用Scala編寫的,需要JVM的支持。
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命令,可以將Kafka的安裝目錄和bin目錄添加到系統的PATH環境變量中。編輯/etc/profile文件,在文件末尾添加以下兩行:
export KAFKA_HOME=/path/to/your/kafka_2.12-3.5.2
export PATH=$PATH:$KAFKA_HOME/bin
然后,使配置生效:
source /etc/profile
在Kafka的安裝目錄下創建data目錄,用于存放Kafka的數據文件。
mkdir -p $KAFKA_HOME/data
在Kafka 2.8.0版本以后,引入了Kraft模式,可以使Kafka在不依賴外部Zookeeper的前提下運行。如果需要使用Zookeeper,可以按照以下步驟啟動:
下載并解壓Zookeeper:
wget https://downloads.apache.org/zookeeper/zookeeper-3.8.0/apache-zookeeper-3.8.0-bin.tar.gz
tar -zvxf apache-zookeeper-3.8.0-bin.tar.gz
創建Zookeeper數據目錄:
mkdir -p $KAFKA_HOME/data/zookeeper
配置Zookeeper:
編輯$KAFKA_HOME/conf/zookeeper.properties文件,設置數據目錄和客戶端連接端口等配置。
啟動Zookeeper:
$KAFKA_HOME/bin/zookeeper-server-start.sh $KAFKA_HOME/conf/zookeeper.properties
在每個Kafka節點上啟動Kafka Broker。首先,進入Kafka的安裝目錄,然后按照以下步驟操作:
創建server.properties配置文件:
cp $KAFKA_HOME/config/server.properties $KAFKA_HOME/config/server.properties.example
nano $KAFKA_HOME/config/server.properties
編輯server.properties文件,設置broker.id、listeners、advertised.listeners、zookeeper.connect等配置項。例如:
broker.id=1
listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://192.168.190.1:9092
zookeeper.connect=192.168.190.1:2181
啟動Kafka Broker:
$KAFKA_HOME/bin/zookeeper-server-start.sh $KAFKA_HOME/config/zookeeper.properties
$KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties
至此,Kafka在Debian上的配置步驟就完成了??梢愿鶕枰M一步配置Kafka集群、主題、權限等。