在Ubuntu 20.04 LTS Focal Fossa上安装Apache 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.在Ubuntu 20.04上安装Apache Kafka。

现在我们在官方网页上下载最新版本的Kafka：

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单位文件。

为Zookeeper服务创建系统单位文件：

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

添加以下行：

[Unit]
Description=Apache Zookeeper service
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

添加以下行：

[Unit]
Description=Apache Kafka Service
Documentation=http://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://:9092

恭喜你！您已经成功安装了Apache Kafka。感谢您使用本教程在Ubuntu 20.04 LTS Focal Fossa系统上安装Apache Kafka。有关其他帮助或有用信息，我们建议您检查Apache Kafka官方网站。