二、删除topic模板:(指定所有zookeeper server IP)
/usr/hdp/2.2.0.0-2041/kafka/bin/kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic name --zookeeper IP01:2181,IP02:2181,IP03:2181
五、修改topic分区(分区数只能增加不能减少)
/usr/hdp/2.2.0.0-2041/kafka/bin/kafka-topics.sh --alter --topic TEST --partitions 60 --zookeeper IP:2181
六、批量删除topic脚本
for i in `/usr/hdp/2.2.0.0-2041/kafka/bin/kafka-topics.sh --list --zookeeper IP:2181`;do /usr/hdp/2.2.0.0-2041/kafka/bin/kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic $i --zookeeper IP:2181,IP:2181,IP:2181
done