在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。
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/Yun40705.html