kafka 清除topic数据脚本

原

kafka 清除topic数据脚本

2018年07月25日 16:57:13 pete1223 阅读数：1028

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

输入 xxx.sh topicname