diff --git a/app/kafka/manager/KafkaCommandActor.scala b/app/kafka/manager/KafkaCommandActor.scala
index 9926a83fa..7398ca09e 100644
--- a/app/kafka/manager/KafkaCommandActor.scala
+++ b/app/kafka/manager/KafkaCommandActor.scala
@@ -73,7 +73,6 @@ class KafkaCommandActor(kafkaCommandActorConfig: KafkaCommandActorConfig) extend
             Future {
               KCCommandResult(Try {
                 kafkaCommandActorConfig.adminUtils.deleteTopic(kafkaCommandActorConfig.curator, topic) //this should work in 0.8.2
-                kafkaCommandActorConfig.curator.delete().deletingChildrenIfNeeded().forPath(ZkUtils.getTopicPath(topic))
               })
             }
           }
diff --git a/test/kafka/manager/TestClusterManagerActor.scala b/test/kafka/manager/TestClusterManagerActor.scala
index cae075a18..7cdcd72af 100644
--- a/test/kafka/manager/TestClusterManagerActor.scala
+++ b/test/kafka/manager/TestClusterManagerActor.scala
@@ -238,10 +238,6 @@ class TestClusterManagerActor extends CuratorAwareTest {
         cmResult.result.get
       }
     }
-    Thread.sleep(3000)
-    withClusterManagerActor(KSGetTopics) { result: TopicList =>
-      assert(!result.list.contains(createTopicName),"Failed to delete topic")
-    }
   }
 
   test("create logkafka") {