kafka的安裝
1. 下載及上傳
此處使用Kafka的2.3.1版本進行安裝,下載地址:http://kafka.apache.org/downloads
下載完成之后將下載好的kafka_2.11-2.3.1.tgz安裝包上傳到所要安裝的Linux服務器上,我的軟件安裝包放在/opt/software/
下
2. 安裝
將Kafka_2.11-2.3.1.tgz解壓在
/opt/apps/
目錄下
[yangqi@xiaoer ~]$ tar -zvxf /opt/software/kafka_2.11-2.3.1.tgz -C /opt/apps/
[yangqi@xiaoer ~]$ cd /opt/apps/
# 進行更名處理,防止以后配置環境變量時方便
[yangqi@xiaoer apps]$ mv kafka_2.11-2.3.1/ kafka-2.3.1/
啟動服務
kafka
使用了zookeeper
,因此在啟動kafka
之前,要先啟動zookeeper
服務(我已經啟動了zookeeper
服務)
直接啟動kafka
服務:
[yangqi@xiaoer apps]$ cd kafka-2.3.1/
[yangqi@xiaoer kafka-2.3.1]$ ./bin/kafka-server-start.sh ./config/server.properties
一般情況下,首次啟動kafka
都會報錯,顯示JVM內存不足:
此時可以修改一下kafka-server-start.sh
的配置,將JVM的內存調小一點
[yangqi@xiaoer kafka-2.3.1]$ vi ./bin/kafka-server.start.sh
再次重新啟動kafka
服務:
[yangqi@xiaoer kafka-2.3.1]$ ./bin/kafka-server-start.sh ./config/server.properties
如果你們的集群和筆者的一樣,zookeeper
集群是單獨安裝的,並沒有安裝在master機器上,那么可能會出現以下錯誤,說明kafka
在連接zookeeper
時連接失敗,可以修改./config/server.properties
中的內容
修改內容如下:(修改成你自己的zookeeper
集群的位置)
重新啟動kafka
服務:(如果沒有報錯則啟動成功)
[yangqi@xiaoer kafka-2.3.1]$ ./bin/kafka-server-start.sh ./config/server.properties
此時可以先使用
Crtl+C
結束kafka
的相關服務
將kafka
服務放到后台啟動:
[yangqi@xiaoer kafka-2.3.1]$ nohup ./bin/kafka-server-start.sh ./config/server.properties >/dev/null 2>&1 &