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端口（生产环境需操作）。

参考来源：