diff --git a/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java b/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java
index 99e1f641dde..a7d7ed550c0 100644
--- a/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java
+++ b/spring-web-reactive/src/main/java/org/springframework/web/server/adapter/DefaultServerWebExchange.java
@@ -20,7 +20,6 @@ import java.util.concurrent.ConcurrentHashMap;
 
 import reactor.core.publisher.FluxProcessor;
 import reactor.core.publisher.Mono;
-import reactor.core.publisher.Processors;
 
 import org.springframework.http.server.reactive.ServerHttpRequest;
 import org.springframework.http.server.reactive.ServerHttpResponse;
diff --git a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java
index 99c8c0523e4..8ac52a6114a 100644
--- a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java
+++ b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/AsyncIntegrationTests.java
@@ -26,7 +26,6 @@ import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
 import reactor.core.publisher.Mono;
 import reactor.core.publisher.ProcessorGroup;
-import reactor.core.publisher.Processors;
 import reactor.core.timer.Timer;
 import reactor.rx.Stream;
 
@@ -51,7 +50,7 @@ import static org.junit.Assert.assertThat;
 @RunWith(Parameterized.class)
 public class AsyncIntegrationTests {
 
-	private final ProcessorGroup asyncGroup = Processors.asyncGroup();
+	private final ProcessorGroup asyncGroup = ProcessorGroup.async();
 
 	private final DataBufferAllocator allocator = new DefaultDataBufferAllocator();