linux contos6.8下部署kafka集群的方法
有3臺服務器,ip分別為192.168.174.10,192.168.174.11,192.168.174.12。
1、官網(wǎng)下載,分別在每臺機器上解壓安裝
# 創(chuàng)建kafka的安裝目錄 mkdir -p /usr/local/software/kafka # 解壓 tar -xvf kafka_2.12-1.1.0.tgz -C /usr/local/software/kafka/
2、修改每臺服務器的/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、修改每臺服務器的$KAFKA_HOME/config下的server.properties文件,修改代理id和日志存放目錄
#指定代理id,borker.id可以任意指定,前提是保證集群內(nèi)每臺機器的broker.id唯一,第二臺機器設(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è)置本機地址,設(shè)置為本服務器的ip地址。如果不設(shè)置會在創(chuàng)建主題和發(fā)送消息時,發(fā)生NOT LEADER FOR PARTITION異常。 host.name=192.168.174.10
4、配置完成后,分別啟動3臺服務器的kafka,啟動kafka前確保zookeeper集群已經(jīng)成功啟動。
kafka-server-start.sh -daemon server.properties
5、驗證是否成功啟動
jps
如果看到kafka進程,說明啟動成功。
另外也可通過zookeeper客戶端查看zookeeper目錄結(jié)構(gòu),如下:
#登錄zookeeper zkCli . sh -server 192.168.174.7:2181 #查看目錄結(jié)構(gòu) ls / #查看已啟動的kafka代理 ls /brokers/ids
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
淺談Linux內(nèi)核創(chuàng)建新進程的全過程
這篇文章主要為大家深入淺出的介紹了Linux內(nèi)核創(chuàng)建新進程的全過程,感興趣的小伙伴們可以參考一下2016-01-01
使用ssh-keygen,實現(xiàn)免密碼登陸linux的方法
下面小編就為大家?guī)硪黄褂胹sh-keygen,實現(xiàn)免密碼登陸linux的方法。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2016-11-11
詳解Linux 安裝 JDK、Tomcat 和 MySQL(圖文并茂)
本文會詳細介紹 Windows 上安裝虛擬機之后,如何在 Linux 中安裝 JDK、Tomcat 和 MySQL 的過程,有興趣的可以了解一下2017-08-08

