Kafka提供了一個存儲、讀取和分析流數據的框架。Kafka最初由LinkedIn開發，並將於2011年初在Apache軟件基金會下開源。
在本文中，我們將向您展示如何在Ubuntu 20.04 LTS上安裝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系統單元文件。
為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。A5互聯https://www.a5idc.net/