在CentOS 7系统上部署Kafka涉及多个步骤和配置，这是一个详细的指南，涵盖了从系统准备、Kafka安装到Zookeeper配置和Kafka节点启动等内容。通过遵循此步骤，您可以在CentOS 7上成功运行Kafka并开始使用其强大的消息传递功能。

一、确保系统环境

1.1 检查Java环境

Kafka依赖Java环境，因此首先确保Java已经正确安装。可以通过以下命令检查Java版本：

java -version

如果尚未安装Java，可以使用以下命令安装Java：

sudo yum install java-1.8.0-openjdk

解释：Kafka需要JVM支持，确保安装Java后，才能正常运行Kafka服务。

二、下载和解压Kafka

2.1 进入安装目录

打开终端，并进入您希望安装Kafka的目录，例如 /opt 目录：

cd /opt

2.2 下载Kafka压缩包

使用 curl命令下载Kafka二进制压缩包：

sudo curl -LO https://downloads.apache.org/kafka/<kafka-version>/kafka_<scala-version>-<kafka-version>.tgz

将 <kafka-version> 替换为您要下载的Kafka版本， <scala-version> 替换为相应的Scala版本。例如：

sudo curl -LO https://downloads.apache.org/kafka/2.13-2.8.0/kafka_2.13-2.8.0.tgz

解释：curl 命令用于下载指定的Kafka版本压缩包，并保存到当前目录。

2.3 解压Kafka压缩包

使用 tar命令解压下载的Kafka压缩包：

sudo tar xvf kafka_<scala-version>-<kafka-version>.tgz

例如：

sudo tar xvf kafka_2.13-2.8.0.tgz

解释：此命令将下载的Kafka压缩包解压到当前目录。

2.4 进入Kafka目录

解压后，进入Kafka的安装目录：

cd kafka_<scala-version>-<kafka-version>

例如：

cd kafka_2.13-2.8.0

三、配置Zookeeper

Kafka依赖Zookeeper来管理集群元数据，因此我们需要配置Zookeeper服务。

3.1 创建Zookeeper配置文件备份

在Kafka的 config目录中为Zookeeper配置文件创建一个备份：

sudo cp config/zookeeper.properties config/zookeeper.properties.bak

3.2 编辑Zookeeper配置文件

使用 nano或其他文本编辑器打开Zookeeper配置文件：

sudo nano config/zookeeper.properties

根据您的需求，修改以下内容：

dataDir=/tmp/zookeeper   # 定义Zookeeper数据存储的目录
clientPort=2181          # Zookeeper监听客户端连接的端口

解释：Zookeeper使用 clientPort 监听客户端请求，dataDir 是存储Zookeeper数据的位置。

四、配置Kafka

4.1 创建Kafka配置文件备份

同样地，在Kafka的 config 目录中为 server.properties 配置文件创建备份：

sudo cp config/server.properties config/server.properties.bak

4.2 编辑Kafka配置文件

使用文本编辑器打开Kafka的配置文件：

sudo nano config/server.properties

根据您的需求，修改以下关键配置项：

broker.id=0                      # Kafka节点ID，集群中每个节点唯一
listeners=PLAINTEXT://:9092       # Kafka监听客户端请求的地址与端口
log.dirs=/tmp/kafka-logs          # Kafka日志存储的目录

解释：broker.id 是集群中每个Kafka节点的唯一标识，listeners 定义了Kafka服务监听的端口，log.dirs 是Kafka日志文件的存储路径。

五、启动Zookeeper和Kafka节点

5.1 启动Zookeeper

Kafka依赖于Zookeeper服务，因此首先需要启动Zookeeper。在Kafka安装目录下，运行以下命令启动Zookeeper：

bin/zookeeper-server-start.sh config/zookeeper.properties

解释：此命令启动Zookeeper服务，Zookeeper将在指定的 clientPort 上监听请求。

5.2 启动Kafka节点

打开另一个终端窗口，进入Kafka安装目录，并启动Kafka节点服务器：

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

解释：此命令启动Kafka节点，Kafka会根据配置文件中的 listeners 信息监听客户端请求。

六、创建Kafka主题

6.1 创建主题

为了使用Kafka服务，我们需要先创建一个主题。打开新的终端窗口，进入Kafka安装目录，并执行以下命令创建主题：

bin/kafka-topics.sh --create --topic <topic-name> --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1

将 <topic-name> 替换为您希望创建的主题名称，例如：

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

解释：--create 表示创建一个新主题，--partitions 设置主题的分区数量，--replication-factor 设置副本因子。此配置适用于单节点集群。

七、发布和订阅消息

7.1 发布消息

使用Kafka生产者发布消息到指定的主题。在终端中运行以下命令：

bin/kafka-console-producer.sh --topic <topic-name> --bootstrap-server localhost:9092

例如：

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

解释：此命令启动Kafka生产者，您可以开始输入消息，消息将被发布到指定的主题。

7.2 订阅消息

使用Kafka消费者订阅并读取发布到主题的消息。在另一个终端中运行以下命令：

bin/kafka-console-consumer.sh --topic <topic-name> --bootstrap-server localhost:9092 --from-beginning

例如：

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

解释：此命令启动Kafka消费者，--from-beginning 参数表示从主题的开头读取所有消息。

八、总结

通过上述步骤，您已经在CentOS 7上成功部署了Kafka并能够创建主题、发布和订阅消息。Kafka提供了强大的分布式消息系统能力，在实际生产环境中，您可能还需要进行更多配置，例如设置多节点集群、配置安全性、调优性能等。