From c27ddf30b3a249e7b527c727f7763a95f40be00e Mon Sep 17 00:00:00 2001 From: Raja Kolli Date: Sun, 21 Apr 2024 11:20:23 +0530 Subject: [PATCH] feat : upgrade to spring boot 3.3.0-RC1 and polish (#480) * feat : upgrade to spring boot 3.3.0-RC1 and polish * revert change * Apply suggestions from code review Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com> --------- Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com> --- .gitpod.Dockerfile | 4 +- .gitpod.yml | 4 +- .vscode/launch.json | 10 +++++ README.md | 16 ++++---- .../spring-boot-kafka-avro-consumer/pom.xml | 4 +- ...BootKafkaAvroConsumerApplicationTests.java | 2 +- .../spring-boot-kafka-avro-producer/pom.xml | 4 +- ...pringBootKafkaAvroProducerApplication.java | 4 +- kafka-dsl-integration/pom.xml | 25 +++++++++++- .../kafkadsl/TestKafkaDslApplication.java | 2 +- .../boot-kafka-reactor-consumer/pom.xml | 25 +++++++++++- ...stBootKafkaReactorConsumerApplication.java | 2 +- .../boot-kafka-reactor-producer/pom.xml | 4 +- ...stBootKafkaReactorProducerApplication.java | 2 +- kafka-spring-boot/README.md | 2 +- kafka-spring-boot/boot-kafka-sample/pom.xml | 2 +- .../TestBootKafkaSampleApplication.java | 2 +- .../pom.xml | 23 ++++++++++- .../TestSpringBootKafkaMultiApplication.java | 2 +- kafka-spring-cloud-sample/pom.xml | 2 +- .../TestCloudKafkaSampleApplication.java | 2 +- .../TestAnalyticsConsumerApplication.java | 2 +- .../pom.xml | 2 +- .../TestAnalyticsProducerApplication.java | 2 +- spring-modulith-outbox-pattern/pom.xml | 39 ++++++++++++++----- .../common/ContainersConfig.java | 2 +- 26 files changed, 141 insertions(+), 49 deletions(-) diff --git a/.gitpod.Dockerfile b/.gitpod.Dockerfile index c8209598..908c5fe0 100644 --- a/.gitpod.Dockerfile +++ b/.gitpod.Dockerfile @@ -3,7 +3,7 @@ FROM gitpod/workspace-full USER root RUN bash -c ". /home/gitpod/.sdkman/bin/sdkman-init.sh \ - && sdk install java 21.0.2-graalce \ - && sdk default java 21.0.2-graalce" + && sdk install java 21.0.3-graalce \ + && sdk default java 21.0.3-graalce" \ No newline at end of file diff --git a/.gitpod.yml b/.gitpod.yml index fb184477..269e1f30 100644 --- a/.gitpod.yml +++ b/.gitpod.yml @@ -9,10 +9,10 @@ image: vscode: extensions: - vscjava.vscode-java-pack - - Vmware.vscode-boot-dev-pack - GabrielBB.vscode-lombok - ms-azuretools.vscode-docker - redhat.java + - Pivotal.vscode-boot-dev-pack ports: - port: 5050 @@ -34,3 +34,5 @@ ports: - port: 9411 visibility: public onOpen: open-browser +: public + onOpen: open-browser diff --git a/.vscode/launch.json b/.vscode/launch.json index 1ac4d3d4..ccea9084 100644 --- a/.vscode/launch.json +++ b/.vscode/launch.json @@ -96,6 +96,16 @@ "projectName": "spring-boot-multiple-producers-consumers", "args": "", "envFile": "${workspaceFolder}/.env" + }, + { + "type": "java", + "name": "Spring Boot-TestCloudKafkaSampleApplication", + "request": "launch", + "cwd": "${workspaceFolder}", + "mainClass": "com.example.cloudkafkasample.TestCloudKafkaSampleApplication", + "projectName": "kafka-spring-cloud-sample", + "args": "", + "envFile": "${workspaceFolder}/.env" } ] } \ No newline at end of file diff --git a/README.md b/README.md index 9812e7ea..3d3cc128 100644 --- a/README.md +++ b/README.md @@ -14,25 +14,23 @@ Kafka has a number of key features that make it a popular choice for data proces - **Low latency**: Kafka is designed for low-latency processing, making it suitable for real-time applications. - - **High-throughput**: Kafka is able to handle high-throughput data streams, allowing it to process large amounts of data in real-time. + - **High-throughput**: Kafka can handle high-throughput data streams, allowing it to process large amounts of data in real-time. - **Flexibility**: Kafka is highly flexible and can be used for a wide range of data processing use cases, including real-time analytics, data pipelines, and event-driven architectures. -This repository contains sample projects integrating with kafka using different mechanisms available +This repository contains sample projects integrating with Kafka using different mechanisms available - - [avro](./kafka-avro/README.md) + - [Kafka Avro type](./kafka-avro/README.md) - [DSL integration](./kafka-dsl-integration/ReadMe.md) - [reactor](./kafka-reactor/README.md) - - [sample](./kafka-sample) + - [sample](./kafka-sample/README.md) - [Examples using spring boot](./kafka-spring-boot/README.md) - - [kafka streams implementation](./kafka-streams/README.md) - - [Kafka implementation using cloud bindings](./spring-cloud/README.md) + - [Kafka implementation using cloud bindings](./kafka-spring-cloud-sample/README.md) + - [Kafka streams implementation](./kafka-streams/README.md) - [Outbox Pattern Implementation using Modulith](./spring-modulith-outbox-pattern/README.md) - - -### Reference +## Reference Copied and modified from - [sivalabs](https://github.com/sivaprasadreddy/kafka-tutorial) diff --git a/kafka-avro/spring-boot-kafka-avro-consumer/pom.xml b/kafka-avro/spring-boot-kafka-avro-consumer/pom.xml index a68725bd..b1fc772e 100644 --- a/kafka-avro/spring-boot-kafka-avro-consumer/pom.xml +++ b/kafka-avro/spring-boot-kafka-avro-consumer/pom.xml @@ -6,7 +6,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.5 + 3.3.0-RC1 com.example @@ -158,7 +158,7 @@ - 1.18.1 + 1.19.2 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 7803fea6..8806080f 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.6.0"; + private static final String CONFLUENT_PLATFORM_VERSION = "7.6.1"; 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/pom.xml b/kafka-avro/spring-boot-kafka-avro-producer/pom.xml index 0940c3da..fec6e77b 100644 --- a/kafka-avro/spring-boot-kafka-avro-producer/pom.xml +++ b/kafka-avro/spring-boot-kafka-avro-producer/pom.xml @@ -6,7 +6,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.5 + 3.3.0-RC1 com.example @@ -154,7 +154,7 @@ - 1.18.1 + 1.19.2 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 34a2e0c0..dd4afb71 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.6.0") + return new KafkaRaftWithExtraListenersContainer("confluentinc/cp-kafka:7.6.1") .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.6.0") + new GenericContainer<>("confluentinc/cp-schema-registry:7.6.1") .withExposedPorts(8085) .withNetworkAliases("schemaregistry") .withNetwork(network) diff --git a/kafka-dsl-integration/pom.xml b/kafka-dsl-integration/pom.xml index a47b3fc9..725be526 100644 --- a/kafka-dsl-integration/pom.xml +++ b/kafka-dsl-integration/pom.xml @@ -5,7 +5,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.5 + 3.3.0-RC1 com.example.integration @@ -84,7 +84,7 @@ - 2.40.0 + 2.42.0 @@ -103,4 +103,25 @@ + + + spring-milestones + Spring Milestones + https://repo.spring.io/milestone + + false + + + + + + spring-milestones + Spring Milestones + https://repo.spring.io/milestone + + false + + + + diff --git a/kafka-dsl-integration/src/test/java/com/example/integration/kafkadsl/TestKafkaDslApplication.java b/kafka-dsl-integration/src/test/java/com/example/integration/kafkadsl/TestKafkaDslApplication.java index 33bbc640..be90c464 100644 --- a/kafka-dsl-integration/src/test/java/com/example/integration/kafkadsl/TestKafkaDslApplication.java +++ b/kafka-dsl-integration/src/test/java/com/example/integration/kafkadsl/TestKafkaDslApplication.java @@ -15,7 +15,7 @@ public class TestKafkaDslApplication { @ServiceConnection KafkaContainer kafkaContainer(DynamicPropertyRegistry dynamicPropertyRegistry) { KafkaContainer kafkaContainer = new KafkaContainer( - DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.1")) .withKraft(); // Connect our Spring application to our Testcontainers Kafka instance dynamicPropertyRegistry.add("spring.kafka.bootstrap-servers", kafkaContainer::getBootstrapServers); diff --git a/kafka-reactor/boot-kafka-reactor-consumer/pom.xml b/kafka-reactor/boot-kafka-reactor-consumer/pom.xml index ee25e315..583383dc 100644 --- a/kafka-reactor/boot-kafka-reactor-consumer/pom.xml +++ b/kafka-reactor/boot-kafka-reactor-consumer/pom.xml @@ -5,7 +5,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.5 + 3.3.0-RC1 com.example.boot.kafka.reactor @@ -143,7 +143,7 @@ - 2.40.0 + 2.42.0 @@ -162,4 +162,25 @@ + + + spring-milestones + Spring Milestones + https://repo.spring.io/milestone + + false + + + + + + spring-milestones + Spring Milestones + https://repo.spring.io/milestone + + false + + + + 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 fc7c068e..6e7527b2 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.6.0")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.1")) .withKraft(); propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers); return kafkaContainer; diff --git a/kafka-reactor/boot-kafka-reactor-producer/pom.xml b/kafka-reactor/boot-kafka-reactor-producer/pom.xml index 185f6c42..655e98c7 100644 --- a/kafka-reactor/boot-kafka-reactor-producer/pom.xml +++ b/kafka-reactor/boot-kafka-reactor-producer/pom.xml @@ -5,7 +5,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.5 + 3.3.0-RC1 com.example.boot.kafka.reactor @@ -105,7 +105,7 @@ - 2.40.0 + 2.42.0 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 4aa9ec59..49e6c834 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.6.0")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.1")) .withKraft(); propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers); return kafkaContainer; diff --git a/kafka-spring-boot/README.md b/kafka-spring-boot/README.md index 00dce3e8..cb50d544 100644 --- a/kafka-spring-boot/README.md +++ b/kafka-spring-boot/README.md @@ -5,5 +5,5 @@ This folder contains sample kafka producer and consumer using java, spring & Spr | Type | Description | |------------------------------------------------------------------------------|-----------------------------------------------------------------------------------------| -| [Spring Boot Kafka Sample](./boot-kafka-sample) | Producing and consuming Messages using Spring Boot | +| [Spring Boot Kafka Sample](./boot-kafka-sample) | Producing and consuming Messages using Spring Boot | | [Multiple Producers & Consumers](./spring-boot-multiple-producers-consumers) | Producing and consuming Messages from Multiple Producer and consumers using Spring Boot | diff --git a/kafka-spring-boot/boot-kafka-sample/pom.xml b/kafka-spring-boot/boot-kafka-sample/pom.xml index 1b85a6b4..aed511c3 100644 --- a/kafka-spring-boot/boot-kafka-sample/pom.xml +++ b/kafka-spring-boot/boot-kafka-sample/pom.xml @@ -5,7 +5,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.5 + 3.3.0-RC1 com.example diff --git a/kafka-spring-boot/boot-kafka-sample/src/test/java/com/example/springbootkafkasample/TestBootKafkaSampleApplication.java b/kafka-spring-boot/boot-kafka-sample/src/test/java/com/example/springbootkafkasample/TestBootKafkaSampleApplication.java index e6f577a3..fe8769e6 100644 --- a/kafka-spring-boot/boot-kafka-sample/src/test/java/com/example/springbootkafkasample/TestBootKafkaSampleApplication.java +++ b/kafka-spring-boot/boot-kafka-sample/src/test/java/com/example/springbootkafkasample/TestBootKafkaSampleApplication.java @@ -14,7 +14,7 @@ public class TestBootKafkaSampleApplication { @ServiceConnection KafkaContainer kafkaContainer() { KafkaContainer kafkaContainer = new KafkaContainer( - DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.0")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.1")) .withKraft(); kafkaContainer.addEnv("KAFKA_NUM_PARTITIONS", "32"); return kafkaContainer; diff --git a/kafka-spring-boot/spring-boot-multiple-producers-consumers/pom.xml b/kafka-spring-boot/spring-boot-multiple-producers-consumers/pom.xml index 7d9196f5..3abb6fca 100644 --- a/kafka-spring-boot/spring-boot-multiple-producers-consumers/pom.xml +++ b/kafka-spring-boot/spring-boot-multiple-producers-consumers/pom.xml @@ -5,7 +5,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.5 + 3.3.0-RC1 com.example.kafka @@ -166,4 +166,25 @@ + + + spring-milestones + Spring Milestones + https://repo.spring.io/milestone + + false + + + + + + spring-milestones + Spring Milestones + https://repo.spring.io/milestone + + false + + + + diff --git a/kafka-spring-boot/spring-boot-multiple-producers-consumers/src/test/java/com/example/springbootkafka/multi/TestSpringBootKafkaMultiApplication.java b/kafka-spring-boot/spring-boot-multiple-producers-consumers/src/test/java/com/example/springbootkafka/multi/TestSpringBootKafkaMultiApplication.java index 3af586b2..2a1a8409 100644 --- a/kafka-spring-boot/spring-boot-multiple-producers-consumers/src/test/java/com/example/springbootkafka/multi/TestSpringBootKafkaMultiApplication.java +++ b/kafka-spring-boot/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.6.0")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.1")) .withKraft() .withReuse(true); // Connect our Spring application to our Testcontainers Kafka instance diff --git a/kafka-spring-cloud-sample/pom.xml b/kafka-spring-cloud-sample/pom.xml index 046c0c02..16ef8eb3 100644 --- a/kafka-spring-cloud-sample/pom.xml +++ b/kafka-spring-cloud-sample/pom.xml @@ -5,7 +5,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.5 + 3.3.0-RC1 com.example diff --git a/kafka-spring-cloud-sample/src/test/java/com/example/cloudkafkasample/TestCloudKafkaSampleApplication.java b/kafka-spring-cloud-sample/src/test/java/com/example/cloudkafkasample/TestCloudKafkaSampleApplication.java index ef45e4fd..ab3e843d 100644 --- a/kafka-spring-cloud-sample/src/test/java/com/example/cloudkafkasample/TestCloudKafkaSampleApplication.java +++ b/kafka-spring-cloud-sample/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.6.0")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.1")) .withKraft() .withReuse(true); dynamicPropertyRegistry.add("spring.cloud.stream.kafka.binder.brokers", kafkaContainer::getBootstrapServers); 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 ca74ebbf..7adcc967 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.6.0"); + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.1"); @Bean @ServiceConnection diff --git a/kafka-streams/analytics-spring-cloud-streams-kafka-producer/pom.xml b/kafka-streams/analytics-spring-cloud-streams-kafka-producer/pom.xml index ac8ea37b..d6fa59a3 100644 --- a/kafka-streams/analytics-spring-cloud-streams-kafka-producer/pom.xml +++ b/kafka-streams/analytics-spring-cloud-streams-kafka-producer/pom.xml @@ -6,7 +6,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.5 + 3.3.0-RC1 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 abd77684..793ca77b 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.6.0")) + new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.1")) .withKraft(); propertyRegistry.add("spring.kafka.bootstrapServers", kafkaContainer::getBootstrapServers); return kafkaContainer; diff --git a/spring-modulith-outbox-pattern/pom.xml b/spring-modulith-outbox-pattern/pom.xml index b2c70962..8c25a5b2 100644 --- a/spring-modulith-outbox-pattern/pom.xml +++ b/spring-modulith-outbox-pattern/pom.xml @@ -7,7 +7,7 @@ org.springframework.boot spring-boot-starter-parent - 3.2.5 + 3.3.0-RC1 com.example.outboxpattern @@ -21,7 +21,7 @@ UTF-8 21 - 1.1.3 + 1.2.0-RC1 2.5.0 ${project.build.directory}/test-results @@ -150,10 +150,10 @@ org.springframework.modulith - spring-modulith-bom - ${spring-modulith.version} - pom - import + spring-modulith-bom + ${spring-modulith.version} + pom + import @@ -261,9 +261,9 @@ 2.38.0 - - - + + + @@ -371,5 +371,24 @@ - + + + spring-milestones + Spring Milestones + https://repo.spring.io/milestone + + false + + + + + + spring-milestones + Spring Milestones + https://repo.spring.io/milestone + + false + + + diff --git a/spring-modulith-outbox-pattern/src/test/java/com/example/outboxpattern/common/ContainersConfig.java b/spring-modulith-outbox-pattern/src/test/java/com/example/outboxpattern/common/ContainersConfig.java index d43d50bd..8783da1e 100644 --- a/spring-modulith-outbox-pattern/src/test/java/com/example/outboxpattern/common/ContainersConfig.java +++ b/spring-modulith-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.6.0")) + DockerImageName.parse("confluentinc/cp-kafka").withTag("7.6.1")) .withKraft(); // Connect our Spring application to our Testcontainers Kafka instance dynamicPropertyRegistry.add("spring.kafka.consumer.bootstrap-servers", kafkaContainer::getBootstrapServers);