kafka在centos上的安裝步驟是什么

以下是在CentOS上安裝Kafka的步驟（以單機為例）：

1. 安裝Java（Kafka依賴Java）

   sudo yum install java-1.8.0-openjdk-devel -y  
   java -version  # 驗證安裝  
   

2. 下載Kafka
   從官網下載對應版本（如3.6.2），使用wget命令：

   wget https://downloads.apache.org/kafka/3.6.2/kafka_2.13-3.6.2.tgz  
   

3. 解壓并配置環境變量

   tar -xzf kafka_2.13-3.6.2.tgz -C /opt  
   mv kafka_2.13-3.6.2 kafka  # 可選：重命名  
   echo 'export KAFKA_HOME=/opt/kafka' >> /etc/profile  
   echo 'export PATH=$PATH:$KAFKA_HOME/bin' >> /etc/profile  
   source /etc/profile  
   

4. 配置Kafka
   編輯config/server.properties：

   • 設置broker.id（單機可設為0）
   • 配置監聽地址listeners=PLAINTEXT://your_server_ip:9092
   • 配置日志路徑log.dirs=/opt/kafka/logs
   • 配置Zookeeper連接zookeeper.connect=localhost:2181

5. 啟動Zookeeper（Kafka依賴）

   cd /opt/kafka  
   bin/zookeeper-server-start.sh config/zookeeper.properties &  
   

6. 啟動Kafka

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

7. 驗證安裝

   • 創建Topic：

     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  
     

   • 生產/消費消息（可選）：

     # 生產者  
     bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092  
     # 消費者  
     bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092  
     

可選步驟：

• 配置開機自啟動（需創建systemd服務文件）。
• 關閉防火墻或放通9092端口（生產環境需操作）。

參考來源：