feat : migrate to use official apache kafka image

rajadilipkolli · Jun 26, 2024 · 4c63b48 · 4c63b48
1 parent ecac74f
commit 4c63b48
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 12 deletions.
diff --git a/catalog-service/src/test/java/com/example/catalogservice/TestCatalogServiceApplication.java b/catalog-service/src/test/java/com/example/catalogservice/TestCatalogServiceApplication.java
@@ -12,8 +12,8 @@ Licensed under MIT License Copyright (c) 2023-2024 Raja Kolli.
 import org.springframework.context.annotation.Bean;
 import org.springframework.test.context.DynamicPropertyRegistry;
 import org.testcontainers.containers.GenericContainer;
-import org.testcontainers.containers.KafkaContainer;
 import org.testcontainers.containers.PostgreSQLContainer;
+import org.testcontainers.kafka.KafkaContainer;
 import org.testcontainers.utility.DockerImageName;
 
 @TestConfiguration(proxyBeanMethods = false)
@@ -37,8 +37,7 @@ PostgreSQLContainer<?> postgreSqlContainer() {
     @ServiceConnection
     KafkaContainer kafkaContainer(DynamicPropertyRegistry dynamicPropertyRegistry) {
         KafkaContainer kafkaContainer =
-                new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0"))
-                        .withKraft()
+                new KafkaContainer(DockerImageName.parse("apache/kafka").withTag("3.7.0"))
                         .withReuse(true);
         dynamicPropertyRegistry.add(
                 "spring.cloud.stream.kafka.binder.brokers", kafkaContainer::getBootstrapServers);

diff --git a/inventory-service/src/test/java/com/example/inventoryservice/TestInventoryApplication.java b/inventory-service/src/test/java/com/example/inventoryservice/TestInventoryApplication.java
@@ -13,7 +13,7 @@ Licensed under MIT License Copyright (c) 2023-2024 Raja Kolli.
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Import;
 import org.testcontainers.containers.GenericContainer;
-import org.testcontainers.containers.KafkaContainer;
+import org.testcontainers.kafka.KafkaContainer;
 import org.testcontainers.utility.DockerImageName;
 
 @TestConfiguration(proxyBeanMethods = false)
@@ -31,8 +31,7 @@ GenericContainer<?> zipkContainer() {
     @Bean
     @ServiceConnection
     KafkaContainer kafkaContainer() {
-        return new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0"))
-                .withKraft()
+        return new KafkaContainer(DockerImageName.parse("apache/kafka").withTag("3.7.0"))
                 .withReuse(true);
     }
 

diff --git a/order-service/src/test/java/com/example/orderservice/TestOrderServiceApplication.java b/order-service/src/test/java/com/example/orderservice/TestOrderServiceApplication.java
@@ -15,7 +15,7 @@ Licensed under MIT License Copyright (c) 2023-2024 Raja Kolli.
 import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
 import org.springframework.context.annotation.Bean;
 import org.testcontainers.containers.GenericContainer;
-import org.testcontainers.containers.KafkaContainer;
+import org.testcontainers.kafka.KafkaContainer;
 import org.testcontainers.utility.DockerImageName;
 
 @TestConfiguration(proxyBeanMethods = false)
@@ -26,8 +26,7 @@ public class TestOrderServiceApplication {
     @ServiceConnection
     @RestartScope
     KafkaContainer kafkaContainer() {
-        return new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0"))
-                .withKraft()
+        return new KafkaContainer(DockerImageName.parse("apache/kafka").withTag("3.7.0"))
                 .withReuse(true);
     }
 

diff --git a/payment-service/src/test/java/com/example/paymentservice/TestPaymentApplication.java b/payment-service/src/test/java/com/example/paymentservice/TestPaymentApplication.java
@@ -6,8 +6,8 @@
 import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
 import org.springframework.context.annotation.Bean;
 import org.testcontainers.containers.GenericContainer;
-import org.testcontainers.containers.KafkaContainer;
 import org.testcontainers.containers.PostgreSQLContainer;
+import org.testcontainers.kafka.KafkaContainer;
 import org.testcontainers.utility.DockerImageName;
 
 @TestConfiguration(proxyBeanMethods = false)
@@ -31,8 +31,7 @@ GenericContainer<?> zipkContainer() {
     @Bean
     @ServiceConnection
     KafkaContainer kafkaContainer() {
-        return new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0"))
-                .withKraft()
+        return new KafkaContainer(DockerImageName.parse("apache/kafka").withTag("3.7.0"))
                 .withReuse(true);
     }