Ubuntu下安裝Kafka詳細步驟

一、安裝Java環境

1、首先檢查操作系統中是否已經安裝好了Java環境。在終端輸入命令：

java -version

如果操作系統尚未安裝Java環境，會提示“Command not found”的信息。

2、安裝OpenJDK：

sudo apt-get update
sudo apt-get install openjdk-8-jdk

3、驗證Java安裝是否成功：

java -version

驗證成功後，會顯示Java的版本信息。

二、下載和解壓縮Kafka

1、前往Apache Kafka官網下載kafka的壓縮包，最好選擇穩定版本:

https://kafka.apache.org/downloads

2、下載完成後，進入下載目錄，解壓縮該文件：

tar -xzf kafka_2.13-2.8.0.tgz

3、切換到Kafka目錄:

cd kafka_2.13-2.8.0

三、啟動Kafka服務器

1、我們需要啟動3個Kafka服務，Zookeeper服務和兩個Broker服務:

bin/zookeeper-server-start.sh config/zookeeper.properties

bin/kafka-server-start.sh config/server.properties

再啟動一個Broker節點

bin/kafka-server-start.sh config/server-1.properties

再啟動一個服務

bin/kafka-server-start.sh config/server-2.properties

這樣就啟動好了Kafka服務器

四、創建topic

1、使用如下命令創建一個名為test的topic：

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test

其中，–replication-factor表示副本因子，即一個消息被保存在幾個Broker節點上，–partitions表示分區數，可根據需求來定。

2、使用如下命令查看已存在的topic列表：

bin/kafka-topics.sh --list --zookeeper localhost:2181

五、啟動生產者和消費者

1、啟動生產者：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

輸入消息後，回車即可發送至Kafka。

2、啟動消費者：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

–from-beginning代表從頭開始消費。

六、清除數據和關閉服務

1、清除數據：

rm -rf /tmp/kafka-logs/*

2、關閉Kafka服務：

bin/kafka-server-stop.sh

3、關閉Zookeeper服務：

bin/zookeeper-server-stop.sh

總結

本篇文章簡要介紹了在Ubuntu上安裝Apache Kafka的詳細步驟，包括安裝Java環境、下載和解壓縮Kafka、啟動Kafka服務器、創建topic、啟動生產者和消費者等。