安裝kafka過程及出現的問題解決


第一步:下載kafka安裝包

下載地址:http://kafka.apache.org/downloads 

解壓 到/usr/local 目錄

tar -zxvf kafka_2.12-2.2.0

第二步 下載zookeerper(之所以下載 是因為我使用kafka自帶的 會出錯)

下載地址:http://zookeeper.apache.org/

第三布:安裝 zookeerper

解壓 tar -zxvf zookeeper-3.4.13

編輯 conf 下的zoo_sample.cfg 文件 

dataDir=/usr/local/zookeeper_data 

在 /usr/local 目錄下創建zookeeper_data目錄

授權 chmod 755 zookeeper_data

將zoo_sample.cfg 重命名 zoo.cfg  不然啟動會出錯

mv zoo_sample.cfg  zoo.cfg

第四步: 啟動 zookeerper

bin/zkServer.sh start

查看 啟動狀態

bin/zkServer.sh status

單機啟動

這個時候用window dos命令 telnet 該服務器 2181 端口 會發現已經通了

第五步:安裝 kafka

編輯 kafka目錄下config文件夾下的server.properties 

advertised.listeners  替換為你服務器ip

注意 listeners=PLAINTEXT://localhost:9092  不要修改為你服務器ip 會啟動出錯

第六步:啟動 kafka

由於之前已經啟動了zookeeper 所以這個時候啟動kafka 時不會再使用kafka自帶的zookeeper

啟動:bin/kafka-server-start.sh config/server.properties &

一般都會成功!

測試:

打開兩個Xshell 端口

一個發送消息:bin/kafka-console-producer.sh --broke-list 47.110.46.94:9092  --topic test

 

另一個接受消息:bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

 

.............................................................................................................................................................

按照過程中出現的問題

本來安裝給kafka是件很簡單是事情,如果過程中出現一個錯誤,可能就會浪費你半天甚至一天時間去百度解決,如果找不到答案會很失望。

1、剛開始安裝kafka 直接啟動 bin/kafka-server-start.sh config/server.properties & 發現2181 這個端口連接不上

在本地window dos命令行用telnet 不通,使用netstat -nltup查看監聽狀態  發現沒有服務監聽2181 端口

於是重新去官網下載zookeeper 然后啟動zookeeper 這個時候才telnet 通,接下來啟動kafka 就順利啟動了。

2、在另一端運行命令bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning 時候發生錯誤

consumer zookeeper is not a recognized option

 --zookeeper是一個過時的啟動方法

正確的啟動方式:bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM