Linux之Kafka安裝
阿新 • • 發佈:2018-11-19
在官網下載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訊息
搭建成功