发表 admin at 2025年2月28日

类别

未分类

标签

如何在 Ubuntu 22.04 中安装 Apache Kafka

Apache Kafka 是由 Apache 软件基金会开发的流媒体平台。该平台是开源的、分布式的，可以安装在任何支持Java的平台上。此外，Apache Kafka 是用 Java 和 Scala 编写的。本指南提供了有关如何在 Ubuntu 22.04 中安装 Apache Kafka 的实践教程。

Apache Kafka 入门

在安装 Apache Kafka 之前，您必须安装 Java 并拥有具有 sudo 权限的用户帐户。此外，为了保证Kafka的正常运行，建议内存为2GB及以上。

以下步骤将指导您如何安装 Apache Kafka。

安装 Java

安装 Kafka 需要 Java。使用以下命令检查版本，检查您的 Ubuntu 是否安装了 Java：

$ java --version

如果未安装Java，请使用以下命令安装Java OpenJDK。

$ sudo apt update

$ sudo apt install default-jdk

创建用户帐户

已安装 Java 后，创建一个非 root 用户帐户。我们还需要通过使用以下命令将用户添加到 sudo 组来授予它一些 sudo 权限：

$ sudo adduser linux

$ sudo adduser linux sudo

登录新创建的用户帐户。

$ su -l linux

安装卡夫卡

您需要从官方下载页面下载最新的 Apache Kafka。使用wget命令下载其二进制文件，如下所示：

$ wget https://downloads.apache.org/kafka/3.2.3/kafka_2.12-3.2.3.tgz

下载二进制文件后，使用 tar 命令将其解压，并将解压后的目录移动到 /opt/kafka.

接下来，为 Zookeeper 和 Kafka 服务创建 systemd 脚本，以帮助启动和停止服务。

使用选择的编辑器创建 systemd 脚本并粘贴以下内容。从动物园管理员开始：

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

粘贴以下内容：

[Unit]

Description=Apache Zookeeper server

Documentation=http://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

保存文件。为 Kafka 创建 systemd 文件并粘贴以下内容：

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

粘贴时，请确保为系统中安装的 Java 设置正确的路径。

[Unit]

Description=Apache Kafka Server

Documentation=http://kafka.apache.org/documentation.html

Requires=zookeeper.service

[Service]

Type=simple

Environment="JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64"

ExecStart=/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties

ExecStop=/opt/kafka/bin/kafka-server-stop.sh

Restart=on-abnormal

[Install]

WantedBy=multi-user.target

完成后，通过重新加载 systemd 守护进程来应用更改：

$ sudo systemctl daemon-reload

接下来，启用 Zookeeper 服务并使用以下命令启动它：

$ sudo systemctl enable zookeeper

$ sudo systemctl start zookeepe<strong>r</strong>

您还需要对 Kafka 执行相同的操作：

$ sudo systemctl enable kafka

$ sudo systemctl start kafka

启动服务后，您可以在 Kafka 中创建主题之前验证其状态。

Kafka 的好处是您可以使用多个脚本。

让我们使用 kafka-topics.sh 脚本创建一个名为 linux1 的新主题，其中包含一个分区和一个复制。使用以下命令：

$ sudo -u linux /opt/kafka/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic linux1

请注意，我们的主题已创建。我们可以查看之前的消息来验证这一点。

或者，您可以使用以下命令中的 -list 选项列出可用主题。它应该返回我们创建的主题：S

$ sudo -u linux /opt/kafka/bin/kafka-topics.sh --list --bootstrap-server localhost:9092

创建 Kafka 主题后，您可以开始在 Kafka-console- Producer.sh 上写入流数据，并检查它是否反映在您的 consumer.sh 中。

打开 shell 并访问我们使用 Producer.sh 创建的主题，如下所示：

$ sudo -u linux /opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic linux1

接下来，打开另一个 shell 并使用 Consumer.sh 访问 Kafka 主题。

$ sudo -u linux /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic linux1 --from-beginning

打开两个 shell 后，您可以在生产者控制台上发送消息。您输入的任何内容都会反映在消费者控制台中，确认我们的 Apache Kafka 已启动并正在运行。

结论

通过本指南，您现在已经掌握了在 Ubuntu 22.04 中安装 Apache Kafka 的所有步骤。希望您能够按照每个步骤安装 Apache Kafka 并创建主题来运行简单的消费者和生产者生产。您可以在大生产中实施相同的方法。