Use H2 to make tests pass

Author: kasramp

pom.xml

@@ -95,6 +95,12 @@
 			<version>1.17.3</version>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>com.h2database</groupId>
+			<artifactId>h2</artifactId>
+			<version>2.1.214</version>
+			<scope>test</scope>
+		</dependency>
 	</dependencies>
 
 	<build>

src/test/java/com/madadipouya/springkafkatest/kafka/UserKafkaTestcontainersTest.java

@@ -31,6 +31,12 @@ class UserKafkaTestcontainersTest {
     @DynamicPropertySource
     static void kafkaProperties(DynamicPropertyRegistry registry) {
         registry.add("spring.kafka.bootstrap-servers", kafkaContainer::getBootstrapServers);
+        // TODO - replace this with test container
+        registry.add("spring.datasource.url", () -> "jdbc:h2:mem:test");
+        registry.add("spring.datasource.driverClassName", () -> "org.h2.Driver");
+        registry.add("spring.datasource.username", () -> "root");
+        registry.add("spring.datasource.password", () -> "secret");
+        registry.add("spring.flyway.enabled", () -> "false");
     }
 
     @Autowired

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

@@ -21,6 +21,8 @@
 import org.springframework.kafka.test.EmbeddedKafkaBroker;
 import org.springframework.kafka.test.context.EmbeddedKafka;
 import org.springframework.kafka.test.utils.KafkaTestUtils;
+import org.springframework.test.context.DynamicPropertyRegistry;
+import org.springframework.test.context.DynamicPropertySource;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -64,6 +66,15 @@ class UserKafkaConsumerTest {
     @Captor
     ArgumentCaptor<Long> offsetArgumentCaptor;
 
+    @DynamicPropertySource
+    static void kafkaProperties(DynamicPropertyRegistry registry) {
+        registry.add("spring.datasource.url", () -> "jdbc:h2:mem:test");
+        registry.add("spring.datasource.driverClassName", () -> "org.h2.Driver");
+        registry.add("spring.datasource.username", () -> "root");
+        registry.add("spring.datasource.password", () -> "secret");
+        registry.add("spring.flyway.enabled", () -> "false");
+    }
+
     @BeforeAll
     void setUp() {
         Map<String, Object> configs = new HashMap<>(KafkaTestUtils.producerProps(embeddedKafkaBroker));

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

@@ -19,6 +19,8 @@
 import org.springframework.kafka.test.EmbeddedKafkaBroker;
 import org.springframework.kafka.test.context.EmbeddedKafka;
 import org.springframework.kafka.test.utils.ContainerTestUtils;
+import org.springframework.test.context.DynamicPropertyRegistry;
+import org.springframework.test.context.DynamicPropertySource;
 
 import java.util.Map;
 import java.util.concurrent.BlockingQueue;
@@ -46,6 +48,15 @@ class UserKafkaProducerTest {
     @Autowired
     private ObjectMapper objectMapper;
 
+    @DynamicPropertySource
+    static void kafkaProperties(DynamicPropertyRegistry registry) {
+        registry.add("spring.datasource.url", () -> "jdbc:h2:mem:test");
+        registry.add("spring.datasource.driverClassName", () -> "org.h2.Driver");
+        registry.add("spring.datasource.username", () -> "root");
+        registry.add("spring.datasource.password", () -> "secret");
+        registry.add("spring.flyway.enabled", () -> "false");
+    }
+
     @BeforeAll
     void setUp() {
         DefaultKafkaConsumerFactory<String, String> consumerFactory = new DefaultKafkaConsumerFactory<>(getConsumerProperties());