第一步:下載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