feat : using apache kafka in testcontainers

rajadilipkolli · Jul 26, 2024 · 24a6307 · 24a6307
1 parent a019c5d
commit 24a6307
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git a/kafka-reactor/boot-kafka-reactor-consumer/pom.xml b/kafka-reactor/boot-kafka-reactor-consumer/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
-        <version>3.3.2</version>
+        <version>3.4.0-M1</version>
         <relativePath/> <!-- lookup parent from repository -->
     </parent>
     <groupId>com.example.boot.kafka.reactor</groupId>

diff --git a/...src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorConsumerApplication.java b/...src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorConsumerApplication.java
@@ -10,8 +10,8 @@
 import org.springframework.boot.testcontainers.service.connection.ServiceConnection;
 import org.springframework.context.annotation.Bean;
 import org.springframework.test.context.DynamicPropertyRegistry;
-import org.testcontainers.containers.KafkaContainer;
 import org.testcontainers.containers.PostgreSQLContainer;
+import org.testcontainers.kafka.KafkaContainer;
 import org.testcontainers.utility.DockerImageName;
 import reactor.kafka.sender.KafkaSender;
 import reactor.kafka.sender.SenderOptions;
@@ -29,11 +29,10 @@ PostgreSQLContainer<?> postgresContainer() {
 
     @Bean
     @ServiceConnection
-    KafkaContainer kafkaContainer(DynamicPropertyRegistry propertyRegistry) {
-        KafkaContainer kafkaContainer = new KafkaContainer(
-                        DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.2"))
-                .withKraft();
-        propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
+    KafkaContainer kafkaContainer(DynamicPropertyRegistry dynamicPropertyRegistry) {
+        KafkaContainer kafkaContainer =
+                new KafkaContainer(DockerImageName.parse("apache/kafka").withTag("3.7.1"));
+        dynamicPropertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
         return kafkaContainer;
     }