原

kafka 清除topic數據腳本

2018年07月25日 16:57:13 pete1223 閱讀數：1028

 

1.  
   #!/bin/sh
2.  
    
3.  
   param= $1
4.  
   echo "============="
5.  
   echo ${param}
6.  
    
7.  
    
8.  
   echo "kafka-topics.sh --zookeeper localhost:2181 --delete --topic ${param}"
9.  
    
10.  
    kafka-topics.sh --zookeeper localhost:2181 --delete --topic ${param}
11.  
     
12.  
    #打印語句
13.  
    echo "kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 3 --topic ${param}"
14.  
     
15.  
    #執行命令
16.  
    kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 3 --topic ${param}

 輸入 xxx.sh topicname