From 11406e924955d93f1db8a78f321e7c45fcf3c46a Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@pivotal.io>
Date: Tue, 22 Sep 2020 21:42:00 +0200
Subject: [PATCH] GH-1981 Fix delayed subscription for reactive consumer

Resolves #1981
---
 .../cloud/stream/function/FunctionConfiguration.java          | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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 3eadc8c17..1f53ef425 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
@@ -418,7 +418,9 @@ public class FunctionConfiguration {
 							}
 						});
 					}
-					flux.subscribe();
+					if (!function.isConsumer()) {
+						flux.subscribe();
+					}
 				});
 			}
 			else {