diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java index 43b13f1a9..267fe9bd8 100644 --- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java +++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java @@ -453,7 +453,8 @@ public class FunctionConfiguration { } if (StringUtils.hasText(functionDefinition) && !shouldNotProcess) { FunctionInvocationWrapper function = functionCatalog.lookup(functionDefinition); - if (function != null && !function.isSupplier()) { + + if (function != null && !function.isSupplier() && functionDefinition.equals(function.getFunctionDefinition())) { this.bindFunctionToDestinations(bindableProxyFactory, functionDefinition); } }