1. 程式人生 > >Linux之Kafka安裝

Linux之Kafka安裝

在官網下載Kafka 下載地址
在這裡插入圖片描述

安裝Kafka(Linux環境)(這裡預設大家安裝好了的自己的虛擬機器,並安裝Xftp 6和Xshell 6)

通過VMware Workstation Pro啟動虛擬機器
登陸後輸入ip addr檢視ip地址
在這裡插入圖片描述

通過Xshell 6連線虛擬機器
輸入剛才查到的ip地址
在這裡插入圖片描述

輸入使用者名稱密碼
在這裡插入圖片描述

通過Xftp 6將下載好的安裝包放到虛擬機器上
建立連線
在這裡插入圖片描述

建立資料夾Kafka並將安裝包放入
在這裡插入圖片描述

在Xshell 6進入該資料夾,輸入tar -zxvf kafka_2.11-2.0.0.tgz 解壓
在這裡插入圖片描述

進入bin目錄
在這裡插入圖片描述

啟動Kafka


輸入./kafka-server-start.sh …/config/server.properties 來啟動Kafka
(預設讀者已經啟動了zookeeper,如果沒有安裝zookeeper,請看文章Linux之zookeeper安裝)
在這裡插入圖片描述

新建立一個連線輸入lsof -i:9092 驗證9092是否被監聽
在這裡插入圖片描述

進入解壓Kafka的目錄輸入
bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic TEST1 --partitions 3 --replication-factor 1 建立名為TEST1 的topic
在這裡插入圖片描述

輸入bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic TEST1 --from-beginning 建立一個消費者用來接收訊息
在這裡插入圖片描述

新建一個連線進入kafka解壓目錄
輸入bin/kafka-console-producer.sh --broker-list localhost:9092 --topic TEST1建立一個生產者傳送訊息
在這裡插入圖片描述

測試傳送接收訊息
在生產者傳送HELLO KAFKA訊息
在這裡插入圖片描述
發現消費者接收到了HELLO KAFKA訊息
在這裡插入圖片描述

搭建成功