Kafka Linux环境下如何部署

以下是Linux环境下部署Kafka的步骤：

1. 安装Java环境

   • CentOS/RHEL: sudo yum install java-1.8.0-openjdk -y
   • Ubuntu/Debian: sudo apt install openjdk-8-jdk -y
   • 验证：java -version

2. 下载并解压Kafka

   • 从官网下载（如kafka_2.13-3.6.2.tgz），上传至服务器，解压至指定目录（如/usr/local/kafka）：
     wget https://archive.apache.org/dist/kafka/3.6.2/kafka_2.13-3.6.2.tgz
tar -zxvf kafka_2.13-3.6.2.tgz -C /usr/local/kafka

3. 配置Kafka

   • 编辑config/server.properties：
     • broker.id：唯一标识（集群中需唯一，默认0）。
     • listeners：监听地址（如PLAINTEXT://0.0.0.0:9092）。
     • log.dirs：日志存储路径（如/usr/local/kafka/logs）。
     • zookeeper.connect：ZooKeeper地址（单机可填localhost:2181，集群需填所有节点）。

4. 启动服务

   • 先启动ZooKeeper（Kafka自带）：
     bin/zookeeper-server-start.sh config/zookeeper.properties &
   • 再启动Kafka：
     bin/kafka-server-start.sh config/server.properties &

5. 测试Kafka

   • 创建Topic：
     bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
   • 启动生产者发送消息：
     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. 停止服务

   • 停止Kafka：bin/kafka-server-stop.sh
   • 停止ZooKeeper：bin/zookeeper-server-stop.sh

注意事项：

• 确保9092（Kafka）和2181（ZooKeeper）端口未被占用，防火墙需开放。
• 生产环境需配置集群、副本、安全认证等。
• 可通过jps命令查看进程是否正常运行。

参考来源：