Minor fix

streamnative · May 20, 2021 · 49eabbb · 49eabbb
1 parent deabb72
commit 49eabbb
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/tests/src/test/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandlerTest.java b/tests/src/test/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandlerTest.java
@@ -349,8 +349,7 @@ private void deleteTopicsByKafkaAdmin(AdminClient admin, Set<String> topicsToDel
     }
 
 
-    //@Test(timeOut = 10000)
-    @Test
+    @Test(timeOut = 10000)
     public void testCreateAndDeleteTopics() throws Exception {
         Properties props = new Properties();
         props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:" + getKafkaBrokerPort());