package org.springframework.cloud.launcher.kafka;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class DeployerApplicationTests {

	@Test
	public void contextLoads() {
	}

}

@@ -44,16 +44,75 @@
 kafka;%0A%0A
+import org.junit.AfterClass;%0Aimport org.junit.BeforeClass;%0A
 import o
@@ -122,24 +122,24 @@
 junit.Test;%0A
-
 import org.j
@@ -280,16 +280,61 @@
 gRunner;
+%0Aimport org.springframework.util.SocketUtils;
 %0A%0A@RunWi
@@ -372,16 +372,16 @@
 ootTest%0A
-
 public c
@@ -413,16 +413,358 @@
 ests %7B%0A%0A
+%09@BeforeClass%0A%09public static void before() %7B%0A%09%09System.setProperty(%22kafka.port%22, String.valueOf(SocketUtils.findAvailableTcpPort()));%0A%09%09System.setProperty(%22zk.port%22, String.valueOf(SocketUtils.findAvailableTcpPort()));%0A%09%7D%0A%0A%09@AfterClass%0A%09public static void after() %7B%0A%09%09System.clearProperty(%22kafka.port%22);%0A%09%09System.clearProperty(%22zk.port%22);%0A%09%7D%0A%0A
 %09@Test%0A%09

fix test that fails with port already in use error