diff --git a/spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/embedded/netty/NettyReactiveWebServerFactory.java b/spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/embedded/netty/NettyReactiveWebServerFactory.java
index fb33f5ac42b..4d805bb118b 100644
--- a/spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/embedded/netty/NettyReactiveWebServerFactory.java
+++ b/spring-boot-project/spring-boot/src/main/java/org/springframework/boot/web/embedded/netty/NettyReactiveWebServerFactory.java
@@ -106,8 +106,8 @@ public class NettyReactiveWebServerFactory extends AbstractReactiveWebServerFact
 						getSsl(), getSslStoreProvider());
 				sslServerCustomizer.customize(options);
 			}
-			if (getCompression() != null && getCompression().getEnabled()) {
-				options.compression(getCompression().getMinResponseSize());
+			if (getCompression() != null) {
+				options.compression(getCompression().getEnabled());
 			}
 			applyCustomizers(options);
 		}).build();
diff --git a/spring-boot-project/spring-boot/src/test/java/org/springframework/boot/web/reactive/server/AbstractReactiveWebServerFactoryTests.java b/spring-boot-project/spring-boot/src/test/java/org/springframework/boot/web/reactive/server/AbstractReactiveWebServerFactoryTests.java
index b88a4c51f4a..6a51c775e5c 100644
--- a/spring-boot-project/spring-boot/src/test/java/org/springframework/boot/web/reactive/server/AbstractReactiveWebServerFactoryTests.java
+++ b/spring-boot-project/spring-boot/src/test/java/org/springframework/boot/web/reactive/server/AbstractReactiveWebServerFactoryTests.java
@@ -273,19 +273,6 @@ public abstract class AbstractReactiveWebServerFactoryTests {
 		assertResponseIsCompressed(response);
 	}
 
-	@Test
-	public void noCompressionForSmallResponse() throws Exception {
-		Assumptions.assumeThat(getFactory())
-				.isInstanceOf(NettyReactiveWebServerFactory.class);
-		Compression compression = new Compression();
-		compression.setEnabled(true);
-		compression.setMinResponseSize(3001);
-		WebClient client = prepareCompressionTest(compression);
-		ResponseEntity<Void> response = client.get().exchange()
-				.flatMap((res) -> res.toEntity(Void.class)).block();
-		assertResponseIsNotCompressed(response);
-	}
-
 	@Test
 	public void noCompressionForMimeType() throws Exception {
 		Assumptions.assumeThat(getFactory())