diff --git a/supplier/spring-sftp-supplier/src/main/java/org/springframework/cloud/fn/supplier/sftp/SftpSupplierConfiguration.java b/supplier/spring-sftp-supplier/src/main/java/org/springframework/cloud/fn/supplier/sftp/SftpSupplierConfiguration.java
index 240d0cb3..a34e9c2b 100644
--- a/supplier/spring-sftp-supplier/src/main/java/org/springframework/cloud/fn/supplier/sftp/SftpSupplierConfiguration.java
+++ b/supplier/spring-sftp-supplier/src/main/java/org/springframework/cloud/fn/supplier/sftp/SftpSupplierConfiguration.java
@@ -107,11 +107,10 @@ public class SftpSupplierConfiguration {
 		Flux<? extends Message<?>> flux = (sftpReadingFlow != null) ? Flux.from(sftpReadingFlow)
 				: sftpMessageFlux(sftpMessageSource, sftpSupplierProperties);
 
-		return () -> flux.doOnSubscribe((sub) -> {
-			if (sftpMessageSource instanceof Lifecycle lifecycle) {
-				lifecycle.start();
-			}
-		});
+		if (sftpMessageSource instanceof Lifecycle lifecycle) {
+			lifecycle.start();
+		}
+		return () -> flux;
 	}
 
 	@Bean