Kafka消息隊列在Linux上怎么用

以下是在Linux上使用Kafka消息隊列的步驟，以單機部署為例：

一、環境準備

1. 安裝Java（Kafka依賴Java 8+）：

   # Ubuntu/Debian  
   sudo apt update && sudo apt install openjdk-11-jdk -y  
   # CentOS/RHEL  
   sudo yum install java-11-openjdk -y  
   java -version  # 驗證安裝  
   

2. 下載并解壓Kafka：

   wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz  
   tar -xzf kafka_2.13-3.6.1.tgz  
   mv kafka_2.13-3.6.1 /opt/kafka  
   cd /opt/kafka  
   

二、配置Kafka

修改config/server.properties關鍵參數：

broker.id=0  
listeners=PLAINTEXT://localhost:9092  # 監聽地址  
log.dirs=/tmp/kafka-logs  # 日志目錄  
zookeeper.connect=localhost:2181  # ZooKeeper地址（單機版可內置）  

三、啟動服務

1. 啟動ZooKeeper（Kafka 2.8+版本需手動啟動，舊版本內置）：

   bin/zookeeper-server-start.sh -daemon config/zookeeper.properties  
   

2. 啟動Kafka：

   bin/kafka-server-start.sh -daemon config/server.properties  
   

四、測試消息隊列

1. 創建Topic：

   bin/kafka-topics.sh --create --topic test-topic \  
   --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1  
   

2. 發送消息（生產者）：

   bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092  
   # 輸入消息后按Enter發送  
   

3. 消費消息（消費者）：

   bin/kafka-console-consumer.sh --topic test-topic --from-beginning --bootstrap-server localhost:9092  
   # 查看歷史消息  
   

五、停止服務

# 停止Kafka  
bin/kafka-server-stop.sh  
# 停止ZooKeeper  
bin/zookeeper-server-stop.sh  

關鍵說明

• 端口配置：確保9092（Kafka）、2181（ZooKeeper）未被占用，可通過sudo firewall-cmd --add-port=9092/tcp開放防火墻。
• 生產環境建議：使用獨立磁盤存儲日志（修改log.dirs）、配置多節點集群提升可用性。
• 集群部署：需配置多節點ZooKeeper和Kafka，設置broker.id和zookeeper.connect參數。

以上步驟參考自，可根據實際需求調整配置。