在Linux上安裝Apache Kafka的步驟如下:
Kafka需要Java運行環境,因此首先需要安裝Java??梢允褂靡韵旅畎惭bOpenJDK:
sudo apt update
sudo apt install openjdk-11-jdk
驗證安裝:
java -version
訪問Apache Kafka的官方下載頁面,找到適合你系統的版本并下載。你可以使用wget命令直接下載:
wget https://downloads.apache.org/kafka/3.2.0/kafka_2.13-3.2.0.tgz
下載完成后,解壓文件:
tar -xzf kafka_2.13-3.2.0.tgz
cd kafka_2.13-3.2.0
Kafka使用Zookeeper來管理集群,因此需要先啟動Zookeeper:
bin/zookeeper-server-start.sh config/zookeeper.properties
在另一個終端窗口中啟動Kafka服務器:
bin/kafka-server-start.sh config/server.properties
創建一個Topic來測試Kafka:
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
列出所有Topic以驗證創建是否成功:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
向Topic發送一條消息:
bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
在提示符下輸入消息并按回車鍵發送。
從Topic消費消息:
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092
你應該能看到之前發送的消息。
停止Kafka服務器:
bin/kafka-server-stop.sh
停止Zookeeper服務器:
bin/zookeeper-server-stop.sh
根據需要,你可以編輯config/server.properties和config/zookeeper.properties文件來配置Kafka和Zookeeper。
在生產環境中,你可能需要考慮以下事項:
通過以上步驟,你應該能夠在Linux系統上成功安裝和運行Apache Kafka。