diff --git a/spring-cloud-launcher/spring-cloud-launcher-kafka/src/test/java/org/springframework/cloud/launcher/kafka/DeployerApplicationTests.java b/spring-cloud-launcher/spring-cloud-launcher-kafka/src/test/java/org/springframework/cloud/launcher/kafka/DeployerApplicationTests.java index c6d16bd..2b0c04b 100644 --- a/spring-cloud-launcher/spring-cloud-launcher-kafka/src/test/java/org/springframework/cloud/launcher/kafka/DeployerApplicationTests.java +++ b/spring-cloud-launcher/spring-cloud-launcher-kafka/src/test/java/org/springframework/cloud/launcher/kafka/DeployerApplicationTests.java @@ -1,14 +1,29 @@ package org.springframework.cloud.launcher.kafka; +import org.junit.AfterClass; +import org.junit.BeforeClass; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; +import org.springframework.util.SocketUtils; @RunWith(SpringRunner.class) @SpringBootTest public class DeployerApplicationTests { + @BeforeClass + public static void before() { + System.setProperty("kafka.port", String.valueOf(SocketUtils.findAvailableTcpPort())); + System.setProperty("zk.port", String.valueOf(SocketUtils.findAvailableTcpPort())); + } + + @AfterClass + public static void after() { + System.clearProperty("kafka.port"); + System.clearProperty("zk.port"); + } + @Test public void contextLoads() { }