diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
index 09e9352f9..c68c17108 100644
--- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
+++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
@@ -425,7 +425,9 @@ public class FunctionConfiguration {
 							}
 						});
 					}
-					flux.subscribe();
+					if (!function.isConsumer()) {
+						flux.subscribe();
+					}
 				});
 			}
 			else {