Run embedded Kafka on random port so that CI pipeline won't fail

Author: kasramp

src/test/java/com/madadipouya/springkafkatest/kafka/consumer/UserKafkaConsumerTest.java

@@ -6,6 +6,7 @@
 import org.apache.kafka.clients.producer.Producer;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.StringSerializer;
+import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;
@@ -27,8 +28,8 @@
 import static org.mockito.Mockito.timeout;
 import static org.mockito.Mockito.verify;
 
-@SpringBootTest
-@EmbeddedKafka(ports = 9092)
+@EmbeddedKafka
+@SpringBootTest(properties = "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}")
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 class UserKafkaConsumerTest {
 
@@ -85,4 +86,9 @@ void testLogKafkaMessages() throws JsonProcessingException {
         assertEquals(0, partitionArgumentCaptor.getValue());
         assertEquals(0, offsetArgumentCaptor.getValue());
     }
+
+    @AfterAll
+    void shutdown() {
+        producer.close();
+    }
 }

src/test/java/com/madadipouya/springkafkatest/kafka/producer/UserKafkaProducerTest.java

@@ -28,8 +28,8 @@
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 
-@SpringBootTest
-@EmbeddedKafka(ports = 9092)
+@EmbeddedKafka
+@SpringBootTest(properties = "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}")
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 class UserKafkaProducerTest {