如何安装 Apache Ubuntu 20.04 LTS 上的 Kafka

在本教程中,我们将向您展示如何安装 Apache Ubuntu 20.04 LTS 上的 Kafka。 对于那些不知道的人,Kafka 是最流行的开源软件,它提供了一个用于存储、读取和分析流数据的框架。 Kafka 最初由 LinkedIn 开发,并于 2011 年初开源 Apache 软件基金会。

本文假设您至少具备 Linux 的基本知识,知道如何使用 shell,最重要的是,您将网站托管在自己的 VPS 上。 安装非常简单,假设您在 root 帐户下运行,如果不是,您可能需要添加 ‘sudo‘ 到命令以获取 root 权限。 我将向您展示逐步安装 Apache Ubuntu 20.04(Focal Fossa)上的 Kafka。 对于 Ubuntu 18.04、16.04 和任何其他基于 Debian 的发行版,如 Linux Mint,您可以按照相同的说明进行操作。

安装 Apache Ubuntu 20.04 LTS Focal Fossa 上的 Kafka

步骤 1. 首先,通过运行以下命令确保所有系统包都是最新的 apt 终端中的命令。

sudo apt update sudo apt upgrade

步骤 2. 安装 Java。

Apache Kafka 需要在您的服务器上安装 Java。 运行以下命令在 Ubuntu 系统上安装 OpenJDK:

sudo apt install openjdk-11-jdk

通过运行以下命令验证 Java 版本:

$ java -version  java version "1.8.0_251" Java(TM) SE Runtime Environment (build 1.8.0_251-b07) Java HotSpot(TM) 64-Bit Server VM (build 25.251-b07, mixed mode)

步骤 3. 安装 Apache Ubuntu 20.04 上的卡夫卡。

现在我们下载最新版本 官网上的卡夫卡

wget https://downloads.apache.org/kafka/2.6.0/kafka_2.13-2.6.0.tgz

然后,解压缩存档文件并移动到另一个位置:

sudo tar xzf kafka_2.13-2.6.0.tgz sudo mv kafka_2.13-2.6.0 /opt/kafka

步骤 4. 创建 Zookeeper 和 Kafka Systemd 单元文件。

创建 systemd zookeeper服务的单元文件:

sudo nano /etc/systemd/system/zookeeper.service

添加以下行:

[Unit] Description=Apache Zookeeper service Documentation=https://zookeeper.apache.org Requires=network.target remote-fs.target After=network.target remote-fs.target  [Service] Type=simple ExecStart=/opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties ExecStop=/opt/kafka/bin/zookeeper-server-stop.sh Restart=on-abnormal  [Install] WantedBy=multi-user.target

接下来,创建 systemd Kafka 服务的单元文件:

sudo nano /etc/systemd/system/kafka.service

添加以下行:

[Unit] Description=Apache Kafka Service Documentation=https://kafka.apache.org/documentation.html Requires=zookeeper.service  [Service] Type=simple Environment="JAVA_HOME=/opt/jdk/jdk1.8.0_251" ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties ExecStop=/opt/kafka/bin/kafka-server-stop.sh  [Install] WantedBy=multi-user.target

重新加载守护进程生效:

sudo systemctl daemon-reload sudo systemctl enable --now zookeeper sudo systemctl enable --now kafka

步骤 5. 在 Kafka 中创建主题。

现在我们将创建一个名为“idroot”的主题,其中包含一个复制因子和分区:

cd /opt/kafka sudo bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-f

要为创建的主题发送一些消息:

sudo bin/kafka-console-producer.sh --broker-list localhost:9092 --topic idoot

提示输入消息:

> Hi > How are you?

使用以下命令,我们可以看到消息列表:

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

第 6 步:从远程机器连接 Kafka。

从远程服务器连接、创建主题和发送消息。 请按照以下步骤操作:

cd /opt/kafka/config

现在寻找 server.properties 并进行一些配置更改:

sudo nano server.properties
listeners=PLAINTEXT://:9092 advertised.listeners=PLAINTEXT://<HOST IP>:9092

恭喜! 您已成功安装 Apache 卡夫卡。 感谢您使用本教程进行安装 Apache Ubuntu 20.04 LTS Focal Fossa 系统上的 Kafka。 如需更多帮助或有用信息,我们建议您查看 官方 Apache 卡夫卡网站.