在 Ubuntu 20.04 上安装 Apache Kafka

当然，以下是关于如何在 Ubuntu 20.04 上安装 Apache Kafka 的文章：

正文

Apache Kafka 是一种分布式消息代理，旨在处理大量实时数据。Kafka 集群具有高度可扩展性和容错性。与 ActiveMQ 和 RabbitMQ 等其他消息代理相比，它还具有更高的吞吐量。尽管它通常用于日志聚合和流媒体分析，但它也可以用于构建实时应用程序和微服务架构。

先决条件

• Ubuntu 20.04 服务器
• 具有 sudo 特权的用户
• Java 8 或更高版本

安装 Java

Apache Kafka 需要 Java 8 或更高版本才能运行。如果您尚未安装 Java，请按照以下步骤进行安装：

sudo apt update
sudo apt install default-jdk

下载 Apache Kafka

转到 Apache Kafka 下载页面并下载适用于您的 Java 版本的最新稳定版本。在撰写本文时，最新稳定版本是 3.3.1。

解压缩 Apache Kafka

下载 Apache Kafka 后，解压缩存档文件：

tar -xzvf kafka_2.13-3.3.1.tgz

这将在当前目录中创建一个名为 kafka_2.13-3.3.1 的目录。

创建 Kafka 用户

您需要创建一个专用用户来运行 Kafka。这将有助于提高安全性并防止其他用户访问 Kafka 数据。

sudo useradd -r -m -U -s /bin/bash kafka

配置 Apache Kafka

现在您需要配置 Apache Kafka。为此，请编辑 kafka_2.13-3.3.1/config/server.properties 文件：

sudo nano kafka_2.13-3.3.1/config/server.properties

并添加或更新以下属性：

broker.id=1
listeners=PLAINTEXT://:9092
zookeeper.connect=localhost:2181

• broker.id ：此属性指定代理的唯一 ID。
• listeners ：此属性指定代理侦听的端口和协议。
• zookeeper.connect ：此属性指定 ZooKeeper 集群的连接信息。

启动 Apache Kafka

现在您可以启动 Apache Kafka：

kafka_2.13-3.3.1/bin/kafka-server-start.sh kafka_2.13-3.3.1/config/server.properties &

验证安装

要验证 Kafka 是否已成功安装，请使用以下命令创建主题：

kafka_2.13-3.3.1/bin/kafka-topics.sh --create --topic test --partitions 1 --replication-factor 1

然后，您可以使用以下命令向主题发送消息：

kafka_2.13-3.3.1/bin/kafka-console-producer.sh --topic test

最后，您可以使用以下命令从主题读取消息：

kafka_2.13-3.3.1/bin/kafka-console-consumer.sh --topic test --from-beginning

总结

您现在已经成功地在 Ubuntu 20.04 上安装和配置了 Apache Kafka。现在，您可以开始使用它来构建实时应用程序和微服务架构。