kafka在centos上怎么安装

在CentOS上安装Kafka的步骤如下：

1. 安装Java环境（Kafka依赖Java）：

   sudo yum install java-1.8.0-openjdk-devel -y  
   java -version  # 验证安装  
   

2. 下载并解压Kafka：

   • 从官网下载对应版本（如kafka_2.13-3.5.2.tgz）：

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

   • 解压到指定目录（如/opt）：

     sudo tar -xzf kafka_2.13-3.5.2.tgz -C /opt  
     sudo mv kafka_2.13-3.5.2 /opt/kafka  # 可选：重命名目录  
     

3. 配置Kafka：

   • 编辑/opt/kafka/config/server.properties：
     • 设置zookeeper.connect=localhost:2181（若Zookeeper在同一服务器）。
     • 配置监听地址listeners=PLAINTEXT://your_server_ip:9092和advertised.listeners（需替换为实际IP）。
     • 修改日志路径log.dirs=/opt/kafka/logs（可选）。
   • （可选）配置Zookeeper数据目录（默认在config目录下，可自定义）。

4. 启动服务：

   • 先启动Zookeeper：

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

   • 再启动Kafka：

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

5. 验证安装：

   • 创建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  
     

6. 设置开机自启（可选）：

   • 创建systemd服务文件（如/etc/systemd/system/kafka.service），添加以下内容：

     [Unit]  
     Description=Apache Kafka Server  
     After=network.target zookeeper.service  
     [Service]  
     Type=simple  
     User=root  
     ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties  
     ExecStop=/opt/kafka/bin/kafka-server-stop.sh  
     Restart=on-failure  
     [Install]  
     WantedBy=multi-user.target  
     

   • 启用服务：

     sudo systemctl daemon-reload  
     sudo systemctl enable kafka  
     sudo systemctl start kafka  
     

注意事项：

• 确保防火墙放通Kafka端口（默认9092）。
• 生产环境中建议配置集群、数据持久化等参数。
• 若需高可用，需部署多个Broker并配置Zookeeper集群。

参考来源：