Centos7中Kafka集群設定服務自啟動

先關閉kafka服務，以便於等會配置完成啟動該服務，測試效果

我的kafka集群有三個節點，分別為：node1,node2,node3

(我的建議是三個節點都配，可以不用在意開機順序，如果只配乙個節點，那麼那台機器要最後啟動，不然的話，就會有些kakfa未啟動)

在node1,node2,node3進行同樣的操作：

進入到 /etc/rc.d/init.d目錄下，建立乙個 kafkacluster 指令碼

vi /etc/rc.d/init.d/kafkacluster

（其中#chkconfig: 345 93 88 要注意啟動級別和關閉級別，因為kafka是依賴zookeeper的，所以zookeeper要比kafka啟動的早，關閉的晚）

配置zookeeper服務自啟動：

#! /bin/bash

#chkconfig: 345 93 88
#description: kafka cluster node1 node2 node3
#processname:kafka_cluster
# kafka**節點位址
hosts=(node1 node2 node3)
# 列印啟動分布式指令碼資訊
mill=`date "+%n"`
tdate=`date "+%y-%m-%d %h:%m:%s,$"`
echo
[$tdate
] info [kafka cluster] begins to execute the $1 operation.
# 執行分布式開啟命令 
function
start()
do smill=`date "+%n"`
stdate=`date "+%y-%m-%d %h:%m:%s,$"`
ssh root@$i
"source /etc/profile;echo [$stdate] info [kafka broker $i] begins to execute the startup operation.;kafka-server-start.sh $kafka_home/config/server.properties>/dev/null" &
sleep 1
done
}# 執行分布式關閉命令 
function stop()do
smill=`date "+%n"`
stdate=`date "+%y-%m-%d %h:%m:%s,$"`
ssh root@$i
"source /etc/profile;echo [$stdate] info [kafka broker $i] begins to execute the shutdown operation.;kafka-server-stop.sh>/dev/null;" &
sleep 1
done
}# 檢視kafka**節點狀態
function status()do
smill=`date "+%n"`
stdate=`date "+%y-%m-%d %h:%m:%s,$"`
ssh root@$i
"source /etc/profile;echo [$stdate] info [kafka broker $i] status message is :;jps | grep kafka;" &
sleep 1
done
}# 判斷輸入的kafka命令引數是否有效
case "$1" in
start
)start;;
stop)
stop
;; status)
status
;;*)echo
"usage: $0 "
retval=1
esac

將 kafkacluster 加入到 chkconfig 服務列表中：

chkconfig --add kafkacluster

以上就配置完成了測試一下：service kafkacluster start即可完成啟動

如有說的不好的地方，請多多指教o(∩_∩)o

centos7搭建kafka集群

安裝環境 集群規劃 伺服器lnh01 伺服器lnh02 伺服器lnh03 zookeeper zookeeper zookeeper kafka kafka kafka 安裝步驟 上傳壓縮包到伺服器 解壓至 opt soft下 命令 tar zxvf kafka 2.12 2.4.1.tgz c o...

centos7搭建kafka集群

7.關閉防火牆 systemctl stop firewalld.service 停止firewall systemctl disable firewalld.service 禁止firewall開機啟動 firewall cmd state 檢視預設防火牆狀態 關閉後顯示notrunning，開啟...

centos7 搭建kafka集群筆記

安裝kafka cd soft tar zxvf kafka 2.11 1.0.0.tgz c usr local mv usr local kafka 2.11 1.0.0 usr local kafka 2.11 環境變數 echo export kafka home usr local kaf...