在Linux上部署Kafka需要滿足一些環境要求,并遵循特定的安裝步驟。以下是詳細指南:
安裝Java:
sudo apt install openjdk-8-jdk
。sudo yum install java-1.8.0-openjdk
。下載Kafka:從Apache Kafka官方網站下載對應版本的Kafka。
解壓Kafka:使用命令 tar -zxvf kafka_x.x.x.tgz
解壓下載的Kafka安裝包。
配置環境變量:編輯 ~/.bashrc
或 ~/.bash_profile
文件,添加以下行:
export KAFKA_HOME=/path/to/kafka
export PATH=$PATH:$KAFKA_HOME/bin
啟動Zookeeper:進入Kafka解壓目錄的 bin
文件夾,執行命令 ./zookeeper-server-start.sh config/zookeeper.properties
。
啟動Kafka:進入Kafka解壓目錄的 bin
文件夾,執行命令 ./kafka-server-start.sh config/server.properties
。
創建主題:使用命令 ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
創建一個測試主題。
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
發送消息到Kafka。./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
確認消息是否被成功消費。通過以上步驟,您應該能夠在Linux系統上成功部署和配置Kafka。