shells/kafka.sh
作者：互联网
1 #!/bin/sh
2 comm=/opt/module/kafka/bin/kafka-server-start.sh
3 commd=/opt/module/kafka/bin/kafka-server-stop.sh
4 topic=/opt/module/kafka/bin/kafka-topics.sh
5 producer=/opt/module/kafka/bin/kafka-console-producer.sh
6 consumer=/opt/module/kafka/bin/kafka-console-consumer.sh
7 conf=/opt/module/kafka/config/server.properties
8 function warning(){
9 echo "----- 无效参数个数，用法为: ----- "
10 echo "----- $0 {start|stop|list} -----"
11 echo "----- $0 {create} {topic} {partions} {replication-factor} -----"
12 echo "----- $0 {delete} {topic} -----"
13 echo "----- $0 {producer} {topic} -----"
14 echo "----- $0 {consumer} {topic} -----"
15 }
16 if [ $# -gt 4 ];
17 then
18 warning
19 exit
20 fi
21 case $1 in
22 start){
23 echo "-------------------启动 kafka 集群---------------"
24 for((i=106 ; i<=108 ; i++ ))
25 do
26 ssh hadoop${i} $comm "-daemon" $conf
27 echo "------hadoop$i:--start kafka服务--done-----"
28 done
29 };;
30 stop){
31 echo "-------------------关闭 kafka 集群---------------"
32 for((i=106 ; i<=108 ; i++ ))
33 do
34 ssh hadoop${i} $commd
35 echo "------hadoop$i:--stop kafka服务--done------"
36 done
37 };;
38 create){
39 echo "--------------create topic $2---------------"
40 $topic "--create" "--topic" $2 "--zookeeper" "hadoop106" "--partitions" $3 "--replication-factor" $4
41 echo "------topic create done------"
42 };;
43 delete){
44 echo "--------------delete topic $2---------------"
45 $topic "--delete" "--topic" $2 "--zookeeper" "hadoop106"
46 echo "------topic delete done------"
47 };;
48 producer){
49 echo "--------------create producer to topic $2---------------"
50 $producer "--broker-list" "hadoop106:9092" "hadoop107:9092" "hadoop108:9092" "--topic" $2
51 echo "------producer create done------"
52 };;
53 consumer){
54 echo "--------------create consumer from topic $2---------------"
55 $consumer "--bootstrap-server" "hadoop106:9092" "hadoop107:9092" "hadoop108:9092" "--from-beginning" "--topic" $2
56 echo "------consumer create done------"
57 };;
58 list){
59 echo "--------------list topic ---------------"
60 $topic "--list" "--zookeeper" "hadoop106"
61 echo "------done------"
62 };;
63
64 *){
65 warning
66 exit
67 };;
68 esac
粘：
#!/bin/sh
comm=/opt/module/kafka/bin/kafka-server-start.sh
commd=/opt/module/kafka/bin/kafka-server-stop.sh
topic=/opt/module/kafka/bin/kafka-topics.sh
producer=/opt/module/kafka/bin/kafka-console-producer.sh
consumer=/opt/module/kafka/bin/kafka-console-consumer.sh
conf=/opt/module/kafka/config/server.properties
function warning(){
echo "----- 无效参数个数，用法为: ----- "
echo "----- $0 {start|stop|list} -----"
echo "----- $0 {create} {topic} {partions} {replication-factor} -----"
echo "----- $0 {delete} {topic} -----"
echo "----- $0 {producer} {topic} -----"
echo "----- $0 {consumer} {topic} -----"
}
if [ $# -gt 4 ];
then
warning
exit
fi
case $1 in
start){
echo "-------------------启动 kafka 集群---------------"
for((i=106 ; i<=108 ; i++ ))
do
ssh hadoop${i} $comm "-daemon" $conf
echo "------hadoop$i:--start kafka服务--done-----"
done
};;
stop){
echo "-------------------关闭 kafka 集群---------------"
for((i=106 ; i<=108 ; i++ ))
do
ssh hadoop${i} $commd
echo "------hadoop$i:--stop kafka服务--done------"
done
};;
create){
echo "--------------create topic $2---------------"
$topic "--create" "--topic" $2 "--zookeeper" "hadoop106" "--partitions" $3 "--replication-factor" $4
echo "------topic create done------"
};;
delete){
echo "--------------delete topic $2---------------"
$topic "--delete" "--topic" $2 "--zookeeper" "hadoop106"
echo "------topic delete done------"
};;
producer){
echo "--------------create producer to topic $2---------------"
$producer "--broker-list" "hadoop106:9092" "hadoop107:9092" "hadoop108:9092" "--topic" $2
echo "------producer create done------"
};;
consumer){
echo "--------------create consumer from topic $2---------------"
$consumer "--bootstrap-server" "hadoop106:9092" "hadoop107:9092" "hadoop108:9092" "--from-beginning" "--topic" $2
echo "------consumer create done------"
};;
list){
echo "--------------list topic ---------------"
$topic "--list" "--zookeeper" "hadoop106"
echo "------done------"
};;
*){
warning
exit
};;
esac
标签：opt,shells,module,echo,sh,-----,kafka 来源： https://www.cnblogs.com/chang09/p/16138886.html