feat!: STREAMP-9951: Upgrade to Spring Boot 3

.github/workflows/build.yml

@@ -14,7 +14,7 @@ jobs:
       - name: Setup JDK
         uses: actions/setup-java@v1
         with:
-          java-version: 11
+          java-version: 17
       - name: Cache local Maven repository
         uses: actions/cache@v2
         with:

.github/workflows/release-patch.yml

@@ -17,7 +17,7 @@ jobs:
       - name: Setup JDK
         uses: actions/setup-java@v2
         with:
-          java-version: 11
+          java-version: 17
           java-package: jdk
           distribution: adopt
           architecture: x64

.github/workflows/release.yml

@@ -27,7 +27,7 @@ jobs:
       - name: Setup JDK
         uses: actions/setup-java@v2
         with:
-          java-version: 11
+          java-version: 17
           java-package: jdk
           distribution: adopt
           architecture: x64

CHANGELOG.md

@@ -5,6 +5,9 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/)
 and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html).
 
 ## [unreleased]
+### Changed
+- Upgrade to Spring Boot 3.
+- 
 ### Fixed
 - KafkaEventReceiver progress logger will actually log the process during normal application bootstrapping.
 

cli/pom.xml

@@ -97,7 +97,7 @@
       <plugin>
         <groupId>com.github.sparow199</groupId>
         <artifactId>apollo-client-maven-plugin</artifactId>
-        <version>3.1.0</version>
+        <version>3.3.1</version>
         <executions>
           <execution>
             <id>graphql-generate-sources</id>

it/pom.xml

@@ -11,6 +11,7 @@
   <artifactId>stream-registry-it</artifactId>
 
   <properties>
+    <spring-test.version>6.0.12</spring-test.version>
     <introspectionFile>${project.build.directory}/graphql-schema/schema.json</introspectionFile>
     <clientPackage>com.expediagroup.streamplatform.streamregistry.graphql.client.test</clientPackage>
   </properties>
@@ -69,6 +70,12 @@
       <artifactId>annotations</artifactId>
       <version>19.0.0</version>
     </dependency>
+    <dependency>
+      <groupId>org.springframework</groupId>
+      <artifactId>spring-test</artifactId>
+      <version>${spring-test.version}</version>
+      <scope>test</scope>
+    </dependency>
   </dependencies>
 
   <build>
@@ -100,7 +107,7 @@
       <plugin>
         <groupId>com.github.sparow199</groupId>
         <artifactId>apollo-client-maven-plugin</artifactId>
-        <version>3.1.0</version>
+        <version>3.3.1</version>
         <executions>
           <execution>
             <id>graphql-generate-sources</id>

it/src/test/java/com/expediagroup/streamplatform/streamregistry/it/StreamRegistryIT.java

@@ -1,5 +1,5 @@
 /**
- * Copyright (C) 2018-2021 Expedia, Inc.
+ * Copyright (C) 2018-2023 Expedia, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -25,7 +25,7 @@
 import org.junit.runners.Suite.SuiteClasses;
 import org.springframework.boot.SpringApplication;
 import org.springframework.context.ConfigurableApplicationContext;
-import org.springframework.util.SocketUtils;
+import org.springframework.test.util.TestSocketUtils;
 import org.testcontainers.containers.KafkaContainer;
 
 import com.expediagroup.streamplatform.streamregistry.StreamRegistryApp;
@@ -56,7 +56,7 @@ public class StreamRegistryIT {
 
   @BeforeClass
   public static void before() {
-    int port = SocketUtils.findAvailableTcpPort();
+    int port = TestSocketUtils.findAvailableTcpPort();
 
     log.info("Starting to run embedded spring app in port {}", port);
 

pom.xml

@@ -72,17 +72,17 @@
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
     <jdk.version>8</jdk.version>
 
-    <confluent.version>6.2.0</confluent.version>
-    <avro.version>1.10.2</avro.version>
-    <apollo.version>2.1.0</apollo.version>
+    <confluent.version>7.4.0</confluent.version>
+    <avro.version>1.11.2</avro.version>
+    <apollo.version>2.5.14</apollo.version>
     <awaitility.version>3.1.6</awaitility.version>
     <bull.version>1.4.7.3</bull.version>
     <guava.version>29.0-jre</guava.version>
     <graphql.version>5.8.1</graphql.version>
     <graphql-java.version>14.0</graphql-java.version>
     <kotlin.version>1.7.10</kotlin.version>
     <slf4j.version>1.7.26</slf4j.version>
-    <spring-boot.version>2.7.0</spring-boot.version>
+    <spring-boot.version>3.1.4</spring-boot.version>
     <testcontainers.version>1.15.3</testcontainers.version>
     <log4j.version>2.17.1</log4j.version>
 

repository/kafka/src/main/java/com/expediagroup/streamplatform/streamregistry/repository/kafka/KafkaConfiguration.java

@@ -15,6 +15,18 @@
  */
 package com.expediagroup.streamplatform.streamregistry.repository.kafka;
 
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileReader;
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Properties;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
 import com.expediagroup.streamplatform.streamregistry.state.DefaultEventCorrelator;
 import com.expediagroup.streamplatform.streamregistry.state.EntityView;
 import com.expediagroup.streamplatform.streamregistry.state.EntityViews;
@@ -23,17 +35,6 @@
 import com.expediagroup.streamplatform.streamregistry.state.internal.EventCorrelator;
 import com.expediagroup.streamplatform.streamregistry.state.kafka.KafkaEventReceiver;
 import com.expediagroup.streamplatform.streamregistry.state.kafka.KafkaEventSender;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.FileReader;
-import java.io.IOException;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Properties;
 
 @Configuration
 public class KafkaConfiguration {

state/core/src/main/java/com/expediagroup/streamplatform/streamregistry/state/DefaultEntityView.java

@@ -15,13 +15,8 @@
  */
 package com.expediagroup.streamplatform.streamregistry.state;
 
-import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
-import com.expediagroup.streamplatform.streamregistry.state.model.event.Event;
-import com.expediagroup.streamplatform.streamregistry.state.model.specification.Specification;
-import lombok.Getter;
-import lombok.NonNull;
-import lombok.RequiredArgsConstructor;
-import lombok.val;
+import static com.expediagroup.streamplatform.streamregistry.state.model.event.Event.LOAD_COMPLETE;
+import static lombok.AccessLevel.PACKAGE;
 
 import java.util.Map;
 import java.util.Optional;
@@ -30,8 +25,14 @@
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
-import static com.expediagroup.streamplatform.streamregistry.state.model.event.Event.LOAD_COMPLETE;
-import static lombok.AccessLevel.PACKAGE;
+import lombok.Getter;
+import lombok.NonNull;
+import lombok.RequiredArgsConstructor;
+import lombok.val;
+
+import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
+import com.expediagroup.streamplatform.streamregistry.state.model.event.Event;
+import com.expediagroup.streamplatform.streamregistry.state.model.specification.Specification;
 
 @RequiredArgsConstructor(access = PACKAGE)
 public class DefaultEntityView implements EntityView {

state/core/src/main/java/com/expediagroup/streamplatform/streamregistry/state/DefaultEntityViewUpdater.java

@@ -15,6 +15,17 @@
  */
 package com.expediagroup.streamplatform.streamregistry.state;
 
+import static com.expediagroup.streamplatform.streamregistry.state.StateValue.deleted;
+import static com.expediagroup.streamplatform.streamregistry.state.StateValue.existing;
+
+import java.util.Map;
+import java.util.Optional;
+
+import lombok.NonNull;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import lombok.val;
+
 import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
 import com.expediagroup.streamplatform.streamregistry.state.model.event.Event;
 import com.expediagroup.streamplatform.streamregistry.state.model.event.SpecificationDeletionEvent;
@@ -23,16 +34,6 @@
 import com.expediagroup.streamplatform.streamregistry.state.model.event.StatusEvent;
 import com.expediagroup.streamplatform.streamregistry.state.model.specification.Specification;
 import com.expediagroup.streamplatform.streamregistry.state.model.status.DefaultStatus;
-import lombok.NonNull;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import lombok.val;
-
-import java.util.Map;
-import java.util.Optional;
-
-import static com.expediagroup.streamplatform.streamregistry.state.StateValue.deleted;
-import static com.expediagroup.streamplatform.streamregistry.state.StateValue.existing;
 
 @Slf4j
 @RequiredArgsConstructor

state/core/src/main/java/com/expediagroup/streamplatform/streamregistry/state/EntityViewUpdater.java

@@ -15,12 +15,12 @@
  */
 package com.expediagroup.streamplatform.streamregistry.state;
 
+import java.util.Optional;
+
 import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
 import com.expediagroup.streamplatform.streamregistry.state.model.event.Event;
 import com.expediagroup.streamplatform.streamregistry.state.model.specification.Specification;
 
-import java.util.Optional;
-
 interface EntityViewUpdater {
 
   <K extends Entity.Key<S>, S extends Specification> Optional<Entity<K, S>> purge(K key);

state/core/src/main/java/com/expediagroup/streamplatform/streamregistry/state/EntityViews.java

@@ -4,9 +4,9 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * <p>
+ *
  * http://www.apache.org/licenses/LICENSE-2.0
- * <p>
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -15,22 +15,24 @@
  */
 package com.expediagroup.streamplatform.streamregistry.state;
 
-import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
-import com.expediagroup.streamplatform.streamregistry.state.model.event.Event;
-import com.expediagroup.streamplatform.streamregistry.state.model.specification.Specification;
-import io.micrometer.core.instrument.MeterRegistry;
-import io.micrometer.core.instrument.Tag;
-import io.micrometer.core.instrument.Tags;
-import lombok.NonNull;
-import lombok.RequiredArgsConstructor;
+import static lombok.AccessLevel.PACKAGE;
 
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.ConcurrentHashMap;
 
-import static lombok.AccessLevel.PACKAGE;
+import lombok.NonNull;
+import lombok.RequiredArgsConstructor;
+
+import io.micrometer.core.instrument.MeterRegistry;
+import io.micrometer.core.instrument.Tag;
+import io.micrometer.core.instrument.Tags;
+
+import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
+import com.expediagroup.streamplatform.streamregistry.state.model.event.Event;
+import com.expediagroup.streamplatform.streamregistry.state.model.specification.Specification;
 
 public final class EntityViews {
 

state/core/src/test/java/com/expediagroup/streamplatform/streamregistry/state/DefaultEntityViewUpdaterTest.java

@@ -15,10 +15,10 @@
  */
 package com.expediagroup.streamplatform.streamregistry.state;
 
-import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
-
 import java.util.Map;
 
+import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
+
 public class DefaultEntityViewUpdaterTest extends EntityViewUpdaterTest {
   @Override
   public EntityViewUpdater entityViewUpdater(Map<Entity.Key<?>, StateValue> entities) {

state/core/src/test/java/com/expediagroup/streamplatform/streamregistry/state/EntityViewUpdaterTest.java

@@ -15,19 +15,6 @@
  */
 package com.expediagroup.streamplatform.streamregistry.state;
 
-import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
-import com.expediagroup.streamplatform.streamregistry.state.model.Entity.DomainKey;
-import com.expediagroup.streamplatform.streamregistry.state.model.event.Event;
-import com.expediagroup.streamplatform.streamregistry.state.model.specification.DefaultSpecification;
-import com.expediagroup.streamplatform.streamregistry.state.model.status.DefaultStatus;
-import lombok.val;
-import org.junit.After;
-import org.junit.Test;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Optional;
-
 import static com.expediagroup.streamplatform.streamregistry.state.SampleEntities.entity;
 import static com.expediagroup.streamplatform.streamregistry.state.SampleEntities.key;
 import static com.expediagroup.streamplatform.streamregistry.state.SampleEntities.specification;
@@ -45,6 +32,21 @@
 import static org.hamcrest.collection.IsMapWithSize.aMapWithSize;
 import static org.junit.Assert.assertThat;
 
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Optional;
+
+import lombok.val;
+
+import org.junit.After;
+import org.junit.Test;
+
+import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
+import com.expediagroup.streamplatform.streamregistry.state.model.Entity.DomainKey;
+import com.expediagroup.streamplatform.streamregistry.state.model.event.Event;
+import com.expediagroup.streamplatform.streamregistry.state.model.specification.DefaultSpecification;
+import com.expediagroup.streamplatform.streamregistry.state.model.status.DefaultStatus;
+
 public abstract class EntityViewUpdaterTest {
 
   private final Map<Entity.Key<?>, StateValue> entities = new HashMap<>();

state/core/src/test/java/com/expediagroup/streamplatform/streamregistry/state/MeteredEntityViewUpdaterTest.java

@@ -4,9 +4,9 @@
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * <p>
+ *
  * http://www.apache.org/licenses/LICENSE-2.0
- * <p>
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -15,21 +15,23 @@
  */
 package com.expediagroup.streamplatform.streamregistry.state;
 
-import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
-import com.expediagroup.streamplatform.streamregistry.state.model.event.Event;
+import static com.expediagroup.streamplatform.streamregistry.state.SampleEntities.specificationEvent;
+import static org.hamcrest.CoreMatchers.is;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertThrows;
+
+import java.util.Map;
+
 import io.micrometer.core.instrument.Counter;
 import io.micrometer.core.instrument.MeterRegistry;
 import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
+
 import org.junit.After;
 import org.junit.Test;
 
-import java.util.Map;
-
-import static com.expediagroup.streamplatform.streamregistry.state.SampleEntities.specificationEvent;
-import static org.hamcrest.CoreMatchers.is;
-import static org.hamcrest.MatcherAssert.assertThat;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertThrows;
+import com.expediagroup.streamplatform.streamregistry.state.model.Entity;
+import com.expediagroup.streamplatform.streamregistry.state.model.event.Event;
 
 public class MeteredEntityViewUpdaterTest extends EntityViewUpdaterTest {