kafka群集管理

奇忠诚

　　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下文件
[root@gdyd-node112 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的版本可以实现同步删除，未经测试，有测试过的朋友欢迎留言交流。指出文档中不足，我会陆续完善。