Centos Kafka消息队列部署与配置指南（新手也能轻松上手的Kafka安装教程）

一、准备工作

在开始安装Kafka之前，请确保你的Centos服务器满足以下条件：

• 操作系统：CentOS 7 或 CentOS 8
• 已安装Java 8或更高版本（Kafka依赖Java运行）
• 具有root权限或sudo权限

1. 安装Java

打开终端，执行以下命令安装OpenJDK：

sudo yum install -y java-1.8.0-openjdk  

安装完成后，验证Java版本：

java -version  

二、下载并安装Kafka

我们将从Apache官网下载最新稳定版的Kafka。截至本文撰写时，推荐使用3.x版本。

cd /optwget https://downloads.apache.org/kafka/3.6.0/kafka_2.13-3.6.0.tgztar -xzf kafka_2.13-3.6.0.tgzmv kafka_2.13-3.6.0 kafka  

三、启动ZooKeeper和Kafka服务

Kafka依赖ZooKeeper进行集群协调。Kafka发行包中自带了ZooKeeper，我们可以直接使用。

1. 启动ZooKeeper

cd /opt/kafkabin/zookeeper-server-start.sh config/zookeeper.properties  

建议在后台运行，可以使用nohup：

nohup bin/zookeeper-server-start.sh config/zookeeper.properties > zookeeper.log 2>&1 &  

2. 启动Kafka Broker

nohup bin/kafka-server-start.sh config/server.properties > kafka.log 2>&1 &  

四、测试Kafka消息队列功能

现在我们来创建一个主题（Topic），并发送/接收消息，验证Kafka是否正常工作。

1. 创建Topic

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

2. 启动生产者（Producer）

bin/kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092  

输入任意消息，例如：Hello Kafka!

3. 启动消费者（Consumer）

bin/kafka-console-consumer.sh --topic test-topic --from-beginning \  --bootstrap-server localhost:9092  

如果一切正常，你应该能看到刚刚发送的消息“Hello Kafka!”被成功接收。

五、常见问题与优化建议

• 防火墙设置：确保9092端口（Kafka默认端口）在防火墙中开放。
• 内存配置：生产环境中应根据服务器资源调整Kafka的JVM参数（位于bin/kafka-server-start.sh中）。
• 开机自启：可编写systemd服务脚本实现Kafka和ZooKeeper的自动启动。

六、总结

通过本教程，你已经成功在Centos系统上完成了Kafka消息队列的基础安装与测试。无论是用于学习还是小型项目，这套配置都足够使用。后续你可以深入学习Kafka的集群搭建、安全认证、性能调优等内容。希望这篇Centos Kafka安装教程能帮助你顺利入门新手入门Kafka的世界！

提示：生产环境建议使用专用ZooKeeper集群，并对Kafka进行高可用配置。