如何在Ubuntu 20.04 LTS上安装Apache Kafka

apache-kafka-logo-1Ubuntu 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://<HOST IP>:9092

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

原创文章,作者:校长,如若转载,请注明出处:https://www.yundongfang.com/Yun40760.html

(0)
打赏 微信扫一扫不于多少! 微信扫一扫不于多少! 支付宝扫一扫礼轻情意重 支付宝扫一扫礼轻情意重
上一篇 2021年3月5日 下午9:53
下一篇 2021年3月5日 下午10:04

相关推荐