diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/AbstractSpringFunctionAdapterInitializer.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/AbstractSpringFunctionAdapterInitializer.java
index 5c44d856b..494777067 100644
--- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/AbstractSpringFunctionAdapterInitializer.java
+++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/AbstractSpringFunctionAdapterInitializer.java
@@ -327,6 +327,12 @@ public abstract class AbstractSpringFunctionAdapterInitializer<C> implements Clo
 				this.supplier = this.catalog.lookup(Supplier.class, functionName);
 				return;
 			}
+			functionName = this.catalog.getNames(Consumer.class).stream()
+					.findFirst().orElseGet(() -> null);
+			if (functionName != null) {
+				this.consumer = this.catalog.lookup(Consumer.class, functionName);
+				return;
+			}
 		}
 		else {
 			name = this.doResolveName(targetContext);