一、安裝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、啟動生產者和消費者等。
原創文章,作者:YBPGC,如若轉載,請註明出處:https://www.506064.com/zh-tw/n/333074.html