diff --git a/spring-web-reactive/src/main/java/org/springframework/core/convert/support/ReactiveStreamsToCompletableFutureConverter.java b/spring-web-reactive/src/main/java/org/springframework/core/convert/support/ReactiveStreamsToCompletableFutureConverter.java
index dcb17c6de2b..692633ec039 100644
--- a/spring-web-reactive/src/main/java/org/springframework/core/convert/support/ReactiveStreamsToCompletableFutureConverter.java
+++ b/spring-web-reactive/src/main/java/org/springframework/core/convert/support/ReactiveStreamsToCompletableFutureConverter.java
@@ -44,10 +44,10 @@ public class ReactiveStreamsToCompletableFutureConverter implements GenericConve
 			return null;
 		}
 		else if (CompletableFuture.class.isAssignableFrom(source.getClass())) {
-			return reactor.core.publisher.convert.CompletableFutureConverter.from((CompletableFuture) source);
+			return reactor.core.converter.CompletableFutureConverter.from((CompletableFuture) source);
 		}
 		else if (CompletableFuture.class.isAssignableFrom(targetType.getResolvableType().getRawClass())) {
-			return reactor.core.publisher.convert.CompletableFutureConverter.fromSingle((Publisher) source);
+			return reactor.core.converter.CompletableFutureConverter.fromSingle((Publisher) source);
 		}
 		return null;
 	}
diff --git a/spring-web-reactive/src/main/java/org/springframework/core/convert/support/ReactiveStreamsToRxJava1Converter.java b/spring-web-reactive/src/main/java/org/springframework/core/convert/support/ReactiveStreamsToRxJava1Converter.java
index 546d49f5607..97a1d3e3a50 100644
--- a/spring-web-reactive/src/main/java/org/springframework/core/convert/support/ReactiveStreamsToRxJava1Converter.java
+++ b/spring-web-reactive/src/main/java/org/springframework/core/convert/support/ReactiveStreamsToRxJava1Converter.java
@@ -20,7 +20,7 @@ import java.util.LinkedHashSet;
 import java.util.Set;
 
 import org.reactivestreams.Publisher;
-import reactor.core.publisher.convert.RxJava1Converter;
+import reactor.core.converter.RxJava1Converter;
 import rx.Observable;
 import rx.Single;
 
@@ -56,10 +56,10 @@ public final class ReactiveStreamsToRxJava1Converter implements GenericConverter
 			return RxJava1Converter.from((Publisher) source);
 		}
 		else if (Single.class.isAssignableFrom(source.getClass())) {
-			return reactor.core.publisher.convert.RxJava1SingleConverter.from((Single) source);
+			return reactor.core.converter.RxJava1SingleConverter.from((Single) source);
 		}
 		else if (Single.class.isAssignableFrom(targetType.getResolvableType().getRawClass())) {
-			return reactor.core.publisher.convert.RxJava1SingleConverter.from((Publisher) source);
+			return reactor.core.converter.RxJava1SingleConverter.from((Publisher) source);
 		}
 		return null;
 	}
diff --git a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyHttpHandlerAdapter.java b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyHttpHandlerAdapter.java
index a3190c8f7c7..91ae66ebdce 100644
--- a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyHttpHandlerAdapter.java
+++ b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyHttpHandlerAdapter.java
@@ -21,7 +21,7 @@ import io.reactivex.netty.protocol.http.server.HttpServerRequest;
 import io.reactivex.netty.protocol.http.server.HttpServerResponse;
 import io.reactivex.netty.protocol.http.server.RequestHandler;
 import org.reactivestreams.Publisher;
-import reactor.core.publisher.convert.RxJava1Converter;
+import reactor.core.converter.RxJava1Converter;
 import rx.Observable;
 
 import org.springframework.util.Assert;
diff --git a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpRequest.java b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpRequest.java
index 3cfa1a71756..ae1bc28ce52 100644
--- a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpRequest.java
+++ b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpRequest.java
@@ -26,8 +26,8 @@ import java.util.Map;
 import io.netty.buffer.ByteBuf;
 import io.netty.handler.codec.http.cookie.Cookie;
 import io.reactivex.netty.protocol.http.server.HttpServerRequest;
+import reactor.core.converter.RxJava1Converter;
 import reactor.core.publisher.Flux;
-import reactor.core.publisher.convert.RxJava1Converter;
 import rx.Observable;
 
 import org.springframework.http.HttpCookie;
diff --git a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpResponse.java b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpResponse.java
index 6fc60699cac..a38685d6759 100644
--- a/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpResponse.java
+++ b/spring-web-reactive/src/main/java/org/springframework/http/server/reactive/RxNettyServerHttpResponse.java
@@ -24,7 +24,7 @@ import io.netty.handler.codec.http.cookie.DefaultCookie;
 import io.reactivex.netty.protocol.http.server.HttpServerResponse;
 import org.reactivestreams.Publisher;
 import reactor.core.publisher.Mono;
-import reactor.core.publisher.convert.RxJava1Converter;
+import reactor.core.converter.RxJava1Converter;
 import rx.Observable;
 
 import org.springframework.http.HttpCookie;
diff --git a/spring-web-reactive/src/test/java/org/springframework/reactive/codec/decoder/StringDecoderTests.java b/spring-web-reactive/src/test/java/org/springframework/reactive/codec/decoder/StringDecoderTests.java
index d185f61af78..e3538a757bd 100644
--- a/spring-web-reactive/src/test/java/org/springframework/reactive/codec/decoder/StringDecoderTests.java
+++ b/spring-web-reactive/src/test/java/org/springframework/reactive/codec/decoder/StringDecoderTests.java
@@ -23,7 +23,7 @@ import java.util.stream.StreamSupport;
 import org.junit.Test;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
-import reactor.core.publisher.convert.RxJava1SingleConverter;
+import reactor.core.converter.RxJava1SingleConverter;
 import reactor.io.buffer.Buffer;
 import rx.Single;