本篇文章給大家分享的是有關(guān)怎么在linux中部署kafka集群,小編覺得挺實(shí)用的,因此分享給大家學(xué)習(xí),希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。
創(chuàng)新互聯(lián)專注于漳州企業(yè)網(wǎng)站建設(shè),響應(yīng)式網(wǎng)站開發(fā),商城系統(tǒng)網(wǎng)站開發(fā)。漳州網(wǎng)站建設(shè)公司,為漳州等地區(qū)提供建站服務(wù)。全流程定制制作,專業(yè)設(shè)計(jì),全程項(xiàng)目跟蹤,創(chuàng)新互聯(lián)專業(yè)和態(tài)度為您提供的服務(wù)
1、官網(wǎng)下載,分別在每臺(tái)機(jī)器上解壓安裝
# 創(chuàng)建kafka的安裝目錄 mkdir -p /usr/local/software/kafka # 解壓 tar -xvf kafka_2.12-1.1.0.tgz -C /usr/local/software/kafka/
2、修改每臺(tái)服務(wù)器的/etc/profile文件,設(shè)置kafka環(huán)境變量,添加如下內(nèi)容
export KAFKA_HOME=/usr/local/software/kafka/kafka_2.12-1.1.0 export PATH=$PATH:$KAFKA_HOME/bin
添加完后重啟配置,命令如下:
source /etc/profile
3、修改每臺(tái)服務(wù)器的$KAFKA_HOME/config下的server.properties文件,修改代理id和日志存放目錄
#指定代理id,borker.id可以任意指定,前提是保證集群內(nèi)每臺(tái)機(jī)器的broker.id唯一,第二臺(tái)機(jī)器設(shè)置為2...以此類推 broker.id=1 #設(shè)置日志目錄 log.dirs=/opt/data/kafka/kafka-logs #設(shè)置zookeeper集群地址 zookeeper.connect=192.168.174.7:2181,192.168.174.8:2181,192.168.174.9:2181 #設(shè)置本機(jī)地址,設(shè)置為本服務(wù)器的ip地址。如果不設(shè)置會(huì)在創(chuàng)建主題和發(fā)送消息時(shí),發(fā)生NOT LEADER FOR PARTITION異常。 host.name=192.168.174.10
4、配置完成后,分別啟動(dòng)3臺(tái)服務(wù)器的kafka,啟動(dòng)kafka前確保zookeeper集群已經(jīng)成功啟動(dòng)。
kafka-server-start.sh -daemon server.properties
5、驗(yàn)證是否成功啟動(dòng)
jps
如果看到kafka進(jìn)程,說明啟動(dòng)成功。
另外也可通過zookeeper客戶端查看zookeeper目錄結(jié)構(gòu),如下:
#登錄zookeeper zkCli . sh -server 192.168.174.7:2181 #查看目錄結(jié)構(gòu) ls / #查看已啟動(dòng)的kafka代理 ls /brokers/ids
Linux是一種免費(fèi)使用和自由傳播的類UNIX操作系統(tǒng),是一個(gè)基于POSIX的多用戶、多任務(wù)、支持多線程和多CPU的操作系統(tǒng),使用Linux能運(yùn)行主要的Unix工具軟件、應(yīng)用程序和網(wǎng)絡(luò)協(xié)議。
以上就是怎么在linux中部署kafka集群,小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘9ぷ鲿?huì)見到或用到的。希望你能通過這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。