Kakfa学习笔记（二）——体验Kafka

在开始体验 Kafka 之前，我们需要先下载并安装 Kafka。

Kafka 的官方网站为：https://kafka.apache.org/ ，在该网站的“Downloads”页面中，我们可以找到 Kafka 的二进制文件，选择合适的版本进行下载。

本篇文章将以 Kafka 2.8.0 版本为例进行演示。

## 安装 Kafka

1. 解压 Kafka 压缩包

将下载的 Kafka 压缩包解压到本地文件夹中，例如：`/usr/local/kafka_2.13-2.8.0/`。

2. 配置环境变量

将 Kafka 的 bin 目录添加到 PATH 环境变量中，以便在终端中能够直接执行 Kafka 的命令。

export PATH=/usr/local/kafka_2.13-2.8.0/bin:$PATH

可以将该命令添加到 `~/.bashrc` 或 `~/.zshrc` 文件中，以便每次打开终端时自动加载。

## 启动 Kafka

Kafka 的启动需要同时启动 ZooKeeper 和 Kafka 服务。

### 启动 ZooKeeper

Kafka 使用 ZooKeeper 来存储集群的元数据和状态信息。在启动 Kafka 之前，我们需要先启动 ZooKeeper。

在终端中执行以下命令来启动 ZooKeeper：

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

该命令将会默认使用 Kafka 的配置文件中的 `zookeeper.properties` 进行启动，该文件位于 Kafka 的安装目录下的 `config` 目录中。

### 启动 Kafka

在启动 Kafka 之前，我们需要先创建一个 Kafka 主题（Topic），用于存储消息。

在终端中执行以下命令来创建一个名为 `test` 的主题：

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

该命令将会使用默认配置，在本地的 Kafka 服务中创建一个名为 `test` 的主题。

接下来，在终端中执行以下命令来启动 Kafka：

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

该命令将会默认使用 Kafka 的配置文件中的 `server.properties` 进行启动，该文件位于 Kafka 的安装目录下的 `config` 目录中。

### 发送和接收消息

Kafka 提供了一个命令行工具 `kafka-console-producer.sh`，用于向 Kafka 主题中发送消息。

在终端中执行以下命令来发送消息：

kafka-console-producer.sh --broker-list localhost:9092 --topic test

该命令将会打开一个新的终端窗口，在该窗口中输入要发送的消息，按下回车键即可发送。

Kafka 还提供了一个命令行工具 `kafka-console-consumer.sh`，用于从 Kafka 主题中接收消息。

在终端中执行以下命令来接收消息：

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

该命令将会打开一个新的终端窗口，用于显示从 Kafka 主题中接收到的消息。

在上述两个终端窗口中，可以分别输入和接收消息，进行 Kafka 的体验和测试。

## 关闭 Kafka

在终端中执行以下命令来关闭 Kafka：

kafka-server-stop.sh

该命令将会停止当前正在运行的 Kafka 服务。

同样地，我们也需要关闭 ZooKeeper 服务：

zookeeper-server-stop.sh

## 总结

通过本篇文章的演示，我们学习了如何下载、安装和启动 Kafka，并且体验了 Kafka 的基本功能，包括创建主题、发送消息和接收消息等。

在实际的生产环境中，我们需要对 Kafka 进行更加详细的配置和管理，以便保证 Kafka 的高可用性、高性能和高可靠性。