fix : issue with connecting to kafka

rajadilipkolli · Oct 29, 2024 · 005b887 · 005b887
1 parent 4ef30cb
commit 005b887
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...ms-kafka-consumer/src/test/java/com/example/analytics/common/ContainersConfiguration.java b/...ms-kafka-consumer/src/test/java/com/example/analytics/common/ContainersConfiguration.java
@@ -4,6 +4,7 @@
 import org.springframework.boot.test.context.TestConfiguration;
 import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
 import org.springframework.context.annotation.Bean;
+import org.springframework.test.context.DynamicPropertyRegistrar;
 import org.testcontainers.kafka.KafkaContainer;
 import org.testcontainers.utility.DockerImageName;
 
@@ -15,4 +16,11 @@ public class ContainersConfiguration {
     KafkaContainer kafkaContainer() {
         return new KafkaContainer(DockerImageName.parse("apache/kafka-native").withTag("3.8.1"));
     }
+
+    @Bean
+    DynamicPropertyRegistrar kafkaProperties(KafkaContainer kafkaContainer) {
+        return (properties) -> {
+            properties.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
+        };
+    }
 }