kafka在centos上怎样配置

以下是在CentOS上配置Kafka的步骤：

1. 安装Java环境

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

2. 下载并解压Kafka

   wget https://downloads.apache.org/kafka/3.6.1/kafka_2.12-3.6.1.tgz  
   tar -zxvf kafka_2.12-3.6.1.tgz  
   sudo mv kafka_2.12-3.6.1 /opt/kafka  
   

3. 配置环境变量
   编辑/etc/profile，添加：

   export KAFKA_HOME=/opt/kafka  
   export PATH=$PATH:$KAFKA_HOME/bin  
   

   使配置生效：

   source /etc/profile  
   

4. 配置Kafka（单节点）
   编辑/opt/kafka/config/server.properties：

   broker.id=0  # 唯一标识  
   listeners=PLAINTEXT://localhost:9092  # 监听地址  
   log.dirs=/tmp/kafka-logs  # 日志目录  
   zookeeper.connect=localhost:2181  # Zookeeper地址（若使用）  
   

5. 启动服务

   • 若使用Zookeeper：

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

   • 若使用Kafka内置Zookeeper（Kraft模式）：
     直接启动Kafka：

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

6. 验证配置

   • 创建Topic：

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

   • 生产者/消费者测试：

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

7. 可选：配置防火墙与开机启动

   • 开放端口：

     sudo firewall-cmd --add-port=9092/tcp --permanent  
     sudo firewall-cmd --reload  
     

   • 开机启动（需编写systemd服务脚本，此处略）

说明：

• 多节点集群需在每台服务器上重复步骤2-5，并确保broker.id唯一、zookeeper.connect指向集群所有节点。
• 生产环境建议配置日志清理策略、副本数等参数，参考server.properties官方文档。