From ac98fb1206f0b293fda15fb618e847507ec66526 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 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 {