Kafka版本 0.8.1-0.8.2
一、创建topic模板：
/usr/hdp/2.2.0.0-2041/kafka/bin/kafka-topics.sh --create --zookeeper IP:2181 --replication-factor 2 --partitions 30 --topic TEST
二、删除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
三、描绘kafka topic partion 信息： /usr/hdp/2.2.0.0-2041/kafka/bin/kafka-topics.sh --describe --zookeeper IP:2181 /usr/hdp/2.2.0.0-2041/kafka/bin/kafka-topics.sh --describe --zookeeper IP:2181 --topic TEST
四、列出topic信息：
/usr/hdp/2.2.0.0-2041/kafka/bin/kafka-topics.sh --list --zookeeper IP:2181 /usr/hdp/2.2.0.0-2041/kafka/bin/kafka-topics.sh --list --zookeeper IP:2181 --topic TEST
五、修改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
七、删除topic之后需要手动删除zookeeper下文件
[[email protected] bin]# cd /usr/hdp/2.2.0.0-2041/zookeeper/bin
echo "rmr /admin" | ./zkCli.sh
echo "rmr /consumers" | ./zkCli.sh
echo "rmr /config" | ./zkCli.sh
echo "rmr /controller" | ./zkCli.sh
echo "rmr /brokers" | ./zkCli.sh
echo "rmr /controller_epoch" | ./zkCli.sh
八、当前kafka版本0.8.1在删除topic的同时，不会删除对应目录下文件，需要手动删除。据说0.90的版本可以实现同步删除，未经测试，有测试过的朋友欢迎留言交流。指出文档中不足，我会陆续完善。