kafka操作topic的方法：

1、檢視topic列表：

      bin/kafka-topics.sh --zookeeper node1:port,node2:port,node3:port/kafkachroot --list

2、刪除topic :

      1) bin/kafka-topics.sh --zookeepernode1:port,node2:port,node3:port/kafkachroot --topic topicName --delete

      2) 刪除kafka儲存目錄（server.properties檔案log.dirs配置，預設為"/tmp/kafka-logs"）相關topic目錄

      3) 刪除zookeeper "/brokers/topics/"目錄下相關topicName：

           rmr /kafkachroot/brokers/topics/topicName   

3、建立topic：

     bin/kafka-topics.sh --zookeeper node1:port,node2:port,node3:port/kafkachroot --topic topicName --create --partitions 2 --replication-factor 1

學習文件：http://blog.csdn.net/code52/article/details/50935849