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官方文档。