[DMAAP-MR] Sonar coverage fix
[dmaap/messagerouter/messageservice.git] / src / test / java / org / onap / dmaap / mr / cambria / embed / KafkaLocal.java
index 17c5bbb..43dcd6c 100644 (file)
@@ -41,7 +41,7 @@ public class KafkaLocal {
                zookeeper = new ZooKeeperLocal(zkProperties);
                zookeeper.run();
                System.out.println("done");
-               
+               Thread.sleep(5000);
                //start local kafka broker
                final scala.Option<String> prefix = scala.Option.apply("kafka");
                kafka = new KafkaServer(kafkaConfig, Time.SYSTEM, prefix, false);