在Linux上部署Kafka并進行服務管理,可以通過以下步驟實現:
Kafka是用Java編寫的,因此首先需要安裝Java運行環境??梢允褂靡韵旅畎惭bOpenJDK 8:
sudo apt update
sudo apt install openjdk-8-jdk
驗證Java安裝成功:
java -version
從Apache Kafka官網下載最新版本的Kafka,然后解壓到指定目錄。例如:
wget https://downloads.apache.org/kafka/3.5.0/kafka_2.12-3.5.0.tgz
tar -xzf kafka_2.12-3.5.0.tgz -C /opt
編輯/etc/profile
文件,添加Kafka和Zookeeper的路徑:
export KAFKA_HOME=/opt/kafka_2.12-3.5.0
export PATH=$PATH:$KAFKA_HOME/bin
進入Kafka解壓目錄的bin
目錄,執行啟動命令:
./zookeeper-server-start.sh config/zookeeper.properties
同樣在Kafka的bin
目錄下,執行啟動命令:
./kafka-server-start.sh config/server.properties
創建主題:
kafka-topics.sh --create --topic my-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 8
查看主題列表:
kafka-topics.sh --list --bootstrap-server localhost:9092
消費消息:
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic
通過上述步驟,你可以在Linux上成功部署Kafka并進行服務管理。如果需要更高級的管理功能,可以考慮使用Kafka Manager或Confluent Control Center等工具。