feat: upgrade to kafka 7.6.0 version in tests

rajadilipkolli · Feb 10, 2024 · cc4d0f3 · cc4d0f3
1 parent 3ccf223
commit cc4d0f3
Show file tree

Hide file tree

Showing 10 changed files with 13 additions and 13 deletions.
diff --git a/...est/java/com/example/springbootkafkaavro/SpringBootKafkaAvroConsumerApplicationTests.java b/...est/java/com/example/springbootkafkaavro/SpringBootKafkaAvroConsumerApplicationTests.java
@@ -35,7 +35,7 @@ class SpringBootKafkaAvroConsumerApplicationTests {
  @Autowired KafkaProducer kafkaProducer;
 
  private static final Network KAFKA_NETWORK = Network.newNetwork();
- private static final String CONFLUENT_PLATFORM_VERSION = "7.5.3";
+ private static final String CONFLUENT_PLATFORM_VERSION = "7.6.0";
  private static final DockerImageName KAFKA_IMAGE =
  DockerImageName.parse("confluentinc/cp-kafka").withTag(CONFLUENT_PLATFORM_VERSION);
  private static final KafkaContainer KAFKA =

diff --git a/...test/java/com/example/springbootkafkaavro/TestSpringBootKafkaAvroProducerApplication.java b/...test/java/com/example/springbootkafkaavro/TestSpringBootKafkaAvroProducerApplication.java
@@ -60,7 +60,7 @@ public Statement apply(Statement base, Description description) {
  @Bean
  @ServiceConnection
  KafkaContainer kafkaContainer() {
- return new KafkaRaftWithExtraListenersContainer("confluentinc/cp-kafka:7.5.3")
+ return new KafkaRaftWithExtraListenersContainer("confluentinc/cp-kafka:7.6.0")
  .withAdditionalListener(() -> "kafka:19092")
  .withKraft()
  .withNetwork(network)
@@ -72,7 +72,7 @@ KafkaContainer kafkaContainer() {
  @DependsOn("kafkaContainer")
  GenericContainer<?> schemaregistry(DynamicPropertyRegistry dynamicPropertyRegistry) {
  GenericContainer<?> schemaRegistry =
- new GenericContainer<>("confluentinc/cp-schema-registry:7.5.3")
+ new GenericContainer<>("confluentinc/cp-schema-registry:7.6.0")
  .withExposedPorts(8085)
  .withNetworkAliases("schemaregistry")
  .withNetwork(network)

diff --git a/...src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorConsumerApplication.java b/...src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorConsumerApplication.java
@@ -29,7 +29,7 @@ PostgreSQLContainer<?> postgresContainer() {
  @ServiceConnection
  KafkaContainer kafkaContainer(DynamicPropertyRegistry propertyRegistry) {
  KafkaContainer kafkaContainer = new KafkaContainer(
- DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
+ DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0"))
  .withKraft();
  propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
  return kafkaContainer;

diff --git a/...src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorProducerApplication.java b/...src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorProducerApplication.java
@@ -24,7 +24,7 @@ public class TestBootKafkaReactorProducerApplication {
  @ServiceConnection
  KafkaContainer kafkaContainer(DynamicPropertyRegistry propertyRegistry) {
  KafkaContainer kafkaContainer = new KafkaContainer(
- DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
+ DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0"))
  .withKraft();
  propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
  return kafkaContainer;

diff --git a/.../src/test/java/com/example/springbootkafka/multi/TestSpringBootKafkaMultiApplication.java b/.../src/test/java/com/example/springbootkafka/multi/TestSpringBootKafkaMultiApplication.java
@@ -22,7 +22,7 @@ GenericContainer<?> zipkinContainer() {
  @ServiceConnection
  KafkaContainer kafkaContainer(DynamicPropertyRegistry dynamicPropertyRegistry) {
  KafkaContainer kafkaContainer = new KafkaContainer(
- DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
+ DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0"))
  .withKraft()
  .withReuse(true);
  // Connect our Spring application to our Testcontainers Kafka instance

diff --git a/...-boot/src/test/java/com/example/springbootkafkasample/TestBootKafkaSampleApplication.java b/...-boot/src/test/java/com/example/springbootkafkasample/TestBootKafkaSampleApplication.java
@@ -13,7 +13,7 @@ public class TestBootKafkaSampleApplication {
  @Bean
  @ServiceConnection
  KafkaContainer kafkaContainer() {
- return new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3")).withKraft();
+ return new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0")).withKraft();
  }
 
  public static void main(String[] args) {

diff --git a/...ing-cloud/src/test/java/com/example/cloudkafkasample/TestCloudKafkaSampleApplication.java b/...ing-cloud/src/test/java/com/example/cloudkafkasample/TestCloudKafkaSampleApplication.java
@@ -16,7 +16,7 @@ class TestCloudKafkaSampleApplication {
  @ServiceConnection
  KafkaContainer kafkaContainer(DynamicPropertyRegistry dynamicPropertyRegistry) {
  KafkaContainer kafkaContainer = new KafkaContainer(
- DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
+ DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0"))
  .withKraft()
  .withReuse(true);
  dynamicPropertyRegistry.add("spring.cloud.stream.kafka.binder.brokers", kafkaContainer::getBootstrapServers);

diff --git a/...ulith-outbox-pattern/src/test/java/com/example/outboxpattern/common/ContainersConfig.java b/...ulith-outbox-pattern/src/test/java/com/example/outboxpattern/common/ContainersConfig.java
@@ -22,7 +22,7 @@ PostgreSQLContainer<?> postgreSQLContainer() {
  @ServiceConnection
  KafkaContainer kafkaContainer(DynamicPropertyRegistry dynamicPropertyRegistry) {
  KafkaContainer kafkaContainer = new KafkaContainer(
- DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
+ DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0"))
  .withKraft();
  // Connect our Spring application to our Testcontainers Kafka instance
  dynamicPropertyRegistry.add("spring.kafka.consumer.bootstrap-servers", kafkaContainer::getBootstrapServers);

diff --git a/...-kafka-consumer/src/test/java/com/example/analytics/TestAnalyticsConsumerApplication.java b/...-kafka-consumer/src/test/java/com/example/analytics/TestAnalyticsConsumerApplication.java
@@ -1,4 +1,4 @@
-/* Licensed under Apache-2.0 2023 */
+/* Licensed under Apache-2.0 2023-2024 */
 package com.example.analytics;
 
 import org.springframework.boot.SpringApplication;
@@ -13,7 +13,7 @@
 public class TestAnalyticsConsumerApplication {
 
  private static final DockerImageName KAFKA_IMAGE_NAME =
- DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3");
+ DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0");
 
  @Bean
  @ServiceConnection

diff --git a/...-kafka-producer/src/test/java/com/example/analytics/TestAnalyticsProducerApplication.java b/...-kafka-producer/src/test/java/com/example/analytics/TestAnalyticsProducerApplication.java
@@ -1,4 +1,4 @@
-/* Licensed under Apache-2.0 2023 */
+/* Licensed under Apache-2.0 2023-2024 */
 package com.example.analytics;
 
 import org.springframework.boot.SpringApplication;
@@ -16,7 +16,7 @@ class TestAnalyticsProducerApplication {
  @ServiceConnection
  KafkaContainer kafkaContainer(DynamicPropertyRegistry propertyRegistry) {
  KafkaContainer kafkaContainer =
- new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"))
+ new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0"))
  .withKraft();
  propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers);
  return kafkaContainer;