Skip to content

Commit

Permalink
Use org.testcontainers.kafka.KafkaContainer
Browse files Browse the repository at this point in the history
  • Loading branch information
@eddumelendez
eddumelendez committed Sep 30, 2024
1 parent 187af7b commit 9ef2abb
Show file tree
Hide file tree
Showing 4 changed files with 12 additions and 20 deletions.
8 changes: 3 additions & 5 deletions ...g-boot-kafka/src/test/java/com/example/consumer/SpringBootKafkaAvroGenericRecordTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,12 +13,11 @@
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.core.KafkaTemplate;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.KafkaContainer;
import org.testcontainers.kafka.KafkaContainer;
import org.testcontainers.containers.Network;
import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;
import org.testcontainers.utility.DockerImageName;

import java.time.Duration;
import java.util.ArrayList;
Expand All @@ -41,9 +40,8 @@ public class SpringBootKafkaAvroGenericRecordTest {

@Container
@ServiceConnection
static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.3.0"))
.withNetwork(network)
.withListener(() -> "kafka:19092");
static KafkaContainer kafka = new KafkaContainer("apache/kafka-native:3.8.0").withNetwork(network)
.withListener("kafka:19092");

@Container
static GenericContainer<?> schemaRegistry = new GenericContainer<>("confluentinc/cp-schema-registry:7.4.0")
Expand Down
8 changes: 3 additions & 5 deletions spring-boot-kafka/src/test/java/com/example/consumer/SpringBootKafkaAvroTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,7 @@
import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;
import org.testcontainers.containers.KafkaContainer;
import org.testcontainers.utility.DockerImageName;
import org.testcontainers.kafka.KafkaContainer;

import java.time.Duration;
import java.util.ArrayList;
Expand All @@ -41,9 +40,8 @@ public class SpringBootKafkaAvroTest {

@Container
@ServiceConnection
static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.3.0"))
.withNetwork(network)
.withListener(() -> "kafka:19092");
static KafkaContainer kafka = new KafkaContainer("apache/kafka-native:3.8.0").withNetwork(network)
.withListener("kafka:19092");

@Container
static GenericContainer<?> schemaRegistry = new GenericContainer<>("confluentinc/cp-schema-registry:7.4.0")
Expand Down
8 changes: 3 additions & 5 deletions ...t-kafka/src/test/java/com/example/consumer/SpringBootKafkaProtoBufDynamicMessageTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -14,12 +14,11 @@
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.core.KafkaTemplate;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.KafkaContainer;
import org.testcontainers.kafka.KafkaContainer;
import org.testcontainers.containers.Network;
import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;
import org.testcontainers.utility.DockerImageName;

import java.time.Duration;
import java.util.ArrayList;
Expand All @@ -42,9 +41,8 @@ public class SpringBootKafkaProtoBufDynamicMessageTest {

@Container
@ServiceConnection
static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.3.0"))
.withNetwork(network)
.withListener(() -> "kafka:19092");
static KafkaContainer kafka = new KafkaContainer("apache/kafka-native:3.8.0").withNetwork(network)
.withListener("kafka:19092");

@Container
static GenericContainer<?> schemaRegistry = new GenericContainer<>("confluentinc/cp-schema-registry:7.4.0")
Expand Down
8 changes: 3 additions & 5 deletions spring-boot-kafka/src/test/java/com/example/consumer/SpringBootKafkaProtoBufTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,12 +13,11 @@
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.core.KafkaTemplate;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.KafkaContainer;
import org.testcontainers.kafka.KafkaContainer;
import org.testcontainers.containers.Network;
import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;
import org.testcontainers.utility.DockerImageName;

import java.time.Duration;
import java.util.ArrayList;
Expand All @@ -41,9 +40,8 @@ public class SpringBootKafkaProtoBufTest {

@Container
@ServiceConnection
static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.3.0"))
.withNetwork(network)
.withListener(() -> "kafka:19092");
static KafkaContainer kafka = new KafkaContainer("apache/kafka-native:3.8.0").withNetwork(network)
.withListener("kafka:19092");

@Container
static GenericContainer<?> schemaRegistry = new GenericContainer<>("confluentinc/cp-schema-registry:7.4.0")
Expand Down

0 comments on commit 9ef2abb

Please sign in to comment.