4 Kafka集群啟動 關閉指令碼

說明：本指令碼基於ssh伺服器免密登入，如集群未配置ssh，參照：《ssh安裝配置》 。

#!/bin/bash

brokers="server1 server2 server3"
kafka_home="/usr/local/services/kafka/kafka_2.11-2.3.0"
kafka_name="kafka_2.11-2.3.0"
echo "info : begin to start kafka cluster ..."
for broker in $brokers
do  echo "info : starting $ on $ ..."
ssh $ -c "source /etc/profile; sh $/bin/kafka-server-start.sh -daemon $/config/server.properties"
if [[ $? -eq 0 ]]; then
echo "info:[$] start successfully"
fidone
echo "info:kafka cluster starts successfully !"

chmod a+x start-kafka-cluster.sh

#!/bin/bash

brokers="server1 server2 server3"
kafka_home="/usr/local/services/kafka/kafka_2.11-2.3.0"
kafka_name="kafka_2.11-2.3.0"
echo "info : begin to stop kafka cluster ..."
for broker in $brokers
do  echo "info : shut down $ on $ ..."
ssh $ "source /etc/profile;bash $/bin/kafka-server-stop.sh"
if [[ $? -ne 0 ]]; then
echo "info : shut down $ on $ is down"
fidone
echo "info : kafka cluster shut down completed!"

chmod a+x stop-kafka-cluster.sh

deepinthought

出處：

shell指令碼啟動kafka集群

前提 kafka集群之間已配置ssh免密登入，kafka集群配置路徑一致 要實現kafka群起指令碼 思路 通過ssh登入後，迴圈啟動每台機器的kafka和zookeeper kafka和zookeeper單機啟動指令碼 remote server.sh bin bash zookeeper 程序號...

Kafka入門 4 kafka基準測試

基準測試 benchmark testing 是一種測量和評估軟體效能指標的活動。我們可以通過基準測試，了解到軟體 硬體的效能水平。主要測試負載的執行時間 傳輸速度 吞吐量 資源佔用率等。測試步驟 啟動kafka集群 建立乙個1個分割槽1個副本的topic benchmark 同時執行生產者 消費者...

大資料集群啟動關閉指令碼

bin bash 選單列印 conf root shell deploy.conf tag hadoop cat eof s 啟動集群 t 關閉集群 q 退出程式 eof 使用者選擇需要維護的內容 while true doread p 請選擇需要操作的內容 helo h action clear ...