diff --git a/kafka-avro/spring-boot-kafka-avro-consumer/src/test/java/com/example/springbootkafkaavro/SpringBootKafkaAvroConsumerApplicationTests.java b/kafka-avro/spring-boot-kafka-avro-consumer/src/test/java/com/example/springbootkafkaavro/SpringBootKafkaAvroConsumerApplicationTests.java index 6e039c57..11c76cbd 100644 --- a/kafka-avro/spring-boot-kafka-avro-consumer/src/test/java/com/example/springbootkafkaavro/SpringBootKafkaAvroConsumerApplicationTests.java +++ b/kafka-avro/spring-boot-kafka-avro-consumer/src/test/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.2"; + private static final String CONFLUENT_PLATFORM_VERSION = "7.5.3"; private static final DockerImageName KAFKA_IMAGE = DockerImageName.parse("confluentinc/cp-kafka").withTag(CONFLUENT_PLATFORM_VERSION); private static final KafkaContainer KAFKA = diff --git a/kafka-avro/spring-boot-kafka-avro-producer/src/test/java/com/example/springbootkafkaavro/TestSpringBootKafkaAvroProducerApplication.java b/kafka-avro/spring-boot-kafka-avro-producer/src/test/java/com/example/springbootkafkaavro/TestSpringBootKafkaAvroProducerApplication.java index c44222fa..43951e81 100644 --- a/kafka-avro/spring-boot-kafka-avro-producer/src/test/java/com/example/springbootkafkaavro/TestSpringBootKafkaAvroProducerApplication.java +++ b/kafka-avro/spring-boot-kafka-avro-producer/src/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.2") + return new KafkaRaftWithExtraListenersContainer("confluentinc/cp-kafka:7.5.3") .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.2") + new GenericContainer<>("confluentinc/cp-schema-registry:7.5.3") .withExposedPorts(8085) .withNetworkAliases("schemaregistry") .withNetwork(network) diff --git a/kafka-reactor/boot-kafka-reactor-consumer/src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorConsumerApplication.java b/kafka-reactor/boot-kafka-reactor-consumer/src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorConsumerApplication.java index 4568af42..176a6223 100644 --- a/kafka-reactor/boot-kafka-reactor-consumer/src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorConsumerApplication.java +++ b/kafka-reactor/boot-kafka-reactor-consumer/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.2")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3")) .withKraft(); propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers); return kafkaContainer; diff --git a/kafka-reactor/boot-kafka-reactor-producer/src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorProducerApplication.java b/kafka-reactor/boot-kafka-reactor-producer/src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorProducerApplication.java index 98613c79..7ec02f81 100644 --- a/kafka-reactor/boot-kafka-reactor-producer/src/test/java/com/example/boot/kafka/reactor/TestBootKafkaReactorProducerApplication.java +++ b/kafka-reactor/boot-kafka-reactor-producer/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.2")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3")) .withKraft(); propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers); return kafkaContainer; diff --git a/kafka-sample/spring-boot-multiple-producers-consumers/src/test/java/com/example/springbootkafka/multi/TestSpringBootKafkaMultiApplication.java b/kafka-sample/spring-boot-multiple-producers-consumers/src/test/java/com/example/springbootkafka/multi/TestSpringBootKafkaMultiApplication.java index e8f5de09..e60baf10 100644 --- a/kafka-sample/spring-boot-multiple-producers-consumers/src/test/java/com/example/springbootkafka/multi/TestSpringBootKafkaMultiApplication.java +++ b/kafka-sample/spring-boot-multiple-producers-consumers/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.2")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3")) .withKraft() .withReuse(true); // Connect our Spring application to our Testcontainers Kafka instance diff --git a/kafka-sample/spring-boot/src/test/java/com/example/springbootkafkasample/TestBootKafkaSampleApplication.java b/kafka-sample/spring-boot/src/test/java/com/example/springbootkafkasample/TestBootKafkaSampleApplication.java index 7f212fb2..7a8cdbe6 100644 --- a/kafka-sample/spring-boot/src/test/java/com/example/springbootkafkasample/TestBootKafkaSampleApplication.java +++ b/kafka-sample/spring-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.2")).withKraft(); + return new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3")).withKraft(); } public static void main(String[] args) { diff --git a/kafka-sample/spring-cloud/src/test/java/com/example/cloudkafkasample/TestCloudKafkaSampleApplication.java b/kafka-sample/spring-cloud/src/test/java/com/example/cloudkafkasample/TestCloudKafkaSampleApplication.java index f51a84a0..ab4c1d9b 100644 --- a/kafka-sample/spring-cloud/src/test/java/com/example/cloudkafkasample/TestCloudKafkaSampleApplication.java +++ b/kafka-sample/spring-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.2")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3")) .withKraft() .withReuse(true); dynamicPropertyRegistry.add("spring.cloud.stream.kafka.binder.brokers", kafkaContainer::getBootstrapServers); diff --git a/kafka-sample/spring-modulith-outbox-pattern/pom.xml b/kafka-sample/spring-modulith-outbox-pattern/pom.xml index be435c96..5515aca0 100644 --- a/kafka-sample/spring-modulith-outbox-pattern/pom.xml +++ b/kafka-sample/spring-modulith-outbox-pattern/pom.xml @@ -26,7 +26,7 @@ ${project.build.directory}/test-results 2.41.1 - 9.0.7 + 9.0.8 1.2.1 3.10.0.2594 0.8.11 diff --git a/kafka-streams/analytics-spring-cloud-streams-kafka-consumer/src/test/java/com/example/analytics/TestAnalyticsConsumerApplication.java b/kafka-streams/analytics-spring-cloud-streams-kafka-consumer/src/test/java/com/example/analytics/TestAnalyticsConsumerApplication.java index cd0cb8ef..05cbcf52 100644 --- a/kafka-streams/analytics-spring-cloud-streams-kafka-consumer/src/test/java/com/example/analytics/TestAnalyticsConsumerApplication.java +++ b/kafka-streams/analytics-spring-cloud-streams-kafka-consumer/src/test/java/com/example/analytics/TestAnalyticsConsumerApplication.java @@ -13,7 +13,7 @@ public class TestAnalyticsConsumerApplication { private static final DockerImageName KAFKA_IMAGE_NAME = - DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.0"); + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3"); @Bean @ServiceConnection diff --git a/kafka-streams/analytics-spring-cloud-streams-kafka-producer/src/test/java/com/example/analytics/TestAnalyticsProducerApplication.java b/kafka-streams/analytics-spring-cloud-streams-kafka-producer/src/test/java/com/example/analytics/TestAnalyticsProducerApplication.java index 16f46127..5fcfa89d 100644 --- a/kafka-streams/analytics-spring-cloud-streams-kafka-producer/src/test/java/com/example/analytics/TestAnalyticsProducerApplication.java +++ b/kafka-streams/analytics-spring-cloud-streams-kafka-producer/src/test/java/com/example/analytics/TestAnalyticsProducerApplication.java @@ -16,7 +16,7 @@ class TestAnalyticsProducerApplication { @ServiceConnection KafkaContainer kafkaContainer(DynamicPropertyRegistry propertyRegistry) { KafkaContainer kafkaContainer = - new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.0")) + new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.5.3")) .withKraft(); propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers); return kafkaContainer;