原

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