安裝Kafka
1 )解壓安裝包
[yanxiaodai@master packge]$ tar -zxvf kafka_2.11-0.11.0.0.tgz -C /home/yanxiaodai/module
2 )修改解壓后的檔案名稱
[yanxiaodai@master module]$ mv kafka_2.11-0.11.0.0.tgz kafka
3 )在kafka目錄下創建logs檔案
[yanxiaodai@master kafka]mkdir logs
4 )修改組態檔
[yanxiaodai@master kafka]cd config/
[yanxiaodai@master config]sudo vi server.properties
修改以下的檔案
#broker的全域唯一編號，不能重復
broker.id=0
#洗掉topic功能使能
delete.topic.enable=true
#kafka運行日志存放的路徑
log.dirs=/home/yanxiaodai/module/kafka/logs
#配置連接Zookeeper集群地址
zookeeper.connect=master:2181,service01:2181,service02:2181
5 )配置環境變數
[yanxiaodai@master module]$ sudo vi /etc/profile
#KAFKA_HOME
export KAFKA_HOME=/home/yanxiaodai/module/kafka
export PATH=$PATH:$KAFKA_HOME/bin
重繪檔案
[yanxiaodai@master module]$ source /etc/profile
6 )分發安裝包
[yanxiaodai@master module]$ scp -r kafka/ yanxiaodai@service01:/home/yanxiaodai/module/
[yanxiaodai@master module]$ scp -r kafka/ yanxiaodai@service02:/home/yanxiaodai/module/
7 )分別在service01、service02上修改組態檔
[yanxiaodai@service01 kafka]cd config/
[yanxiaodai@service01 config]sudo vi server.properties
#broker的全域唯一編號，不能重復
broker.id=1
[yanxiaodai@service02 kafka]cd config/
[yanxiaodai@service02 config]sudo vi server.properties
#broker的全域唯一編號，不能重復
broker.id=2
8 )啟動
啟動kafka之前先要啟動zookeeper
依次在master、service01、service02節點上啟動kafka
[yanxiaodia@mster kafka]$ bin/kafka-server-start.sh config/server.properties &
[yanxiaodai@service kafka]$ bin/kafka-server-start.sh config/server.properties &
[yanxiaodai@service kafka]$ bin/kafka-server-start.sh config/server.properties &
9 )關閉
關閉kafka時，顯示報錯：No kafka server to stop，
應當修改 kafka-server-stop.sh 腳本
[yanxiaodia@mster bin]$ sudo vi kafka-server-stop.sh
修改前：
PIDS=$(ps ax | grep -i 'kafka.Kafka' | grep java | grep -v grep | awk '{print $1}')
修改后：
PIDS=$(jps -lm | grep -i 'kafka.Kafka' | awk '{print $1}')
使用
ps -lm命令列出所有的java行程，然后通過管道，利用grep -i 'kafka.Kafka'命令將kafka行程篩出來，最后再接一管道命令，利用awk將行程號取出來，
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/236559.html
標籤：其他
上一篇：Shell條件測驗陳述句
下一篇：大資料殺熟！我被美團會員割了韭菜