2015-06-01 56 views
2

我想創建卡夫卡0.8.2主題創建之前:檢查卡夫卡主題的存在,通過使用Java中

 AdminUtils.createTopic(zkClient, myTopic, 2, 1,properties); 

如果我運行的代碼不止一次在本地進行測試更多,失敗因爲該主題已經創建。有沒有辦法在創建主題前檢查主題是否存在?對於listTopicsdescribeTopicTopicCommand api似乎不會返回任何內容。

回答

2

我想說

if(!AdminUtils.topicExists(zkClient, myTopic)){ 
    AdminUtils.createTopic(zkClient, myTopic, 2, 1,properties); 
}