1. 简介

Apache Kafka 是一个分布式流处理平台，用于构建实时数据管道和流应用程序。在 Ubuntu 系统上配置 Kafka 是处理巨大数据的关键步骤之一。本文将指导您完成 Kafka 的安装、配置和测试过程。

2. 系统准备

2.1 安装 Java

Kafka 需要 Java 运行周围。您能用 OpenJDK 或 Oracle JDK。

sudo apt update
sudo apt install openjdk-11-jdk

2.2 验证 Java 安装

用以下命令验证 Java 是不是已正确安装：

java -version

3. 下载 Kafka

访问 Apache Kafka 官方网站下载最新鲜版本的 Kafka。您能用 wget 命令下载：

wget https://archive.apache.org/dist/kafka/3.2.0/kafka_2.13-3.2.0.tgz

3.1 解压 Kafka

解压下载的文件：

tar -xzf kafka_2.13-3.2.0.tgz

解压后Kafka 将被安装在 kafka_2.13-3.2.0 目录下。

4. 配置 Kafka

4.1 修改配置文件

修改 Kafka 配置文件，通常位于 config 目录下。根据需要调整配置，比方说 server.properties 文件。

4.2 配置 Zookeeper

Kafka 用 Zookeeper 进行集群管理。确保 Zookeeper 正确配置并运行。

5. 启动 Kafka

5.1 启动 Zookeeper

在另一个终端窗口中启动 Zookeeper：

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

在另一个终端窗口中启动 Kafka 服务器：

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

6. 创建主题

6.1 创建 Kafka 主题

创建一个 Kafka 主题，比方说 my-topic

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

6.2 列出全部主题

列出全部主题以验证 my-topic 是不是已创建：

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

7. 生产者和消费者

7.1 发送消息到 Kafka

用 Kafka 自带的命令行工具发送消息到 my-topic

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

在终端中输入消息并按回车键发送。

7.2 从 Kafka 消费消息

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

8. 验证 Kafka 主题

8.1 查看 Kafka 主题的详细信息

查看 my-topic 的详细信息：

bin/kafka-topics.sh --describe --topic my-topic --bootstrap-server localhost:9092

9.

通过以上步骤，您已经在 Ubuntu 上成功配置了 Apache Kafka。您能根据需要进一步调整和 Kafka 的配置。

---