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 bc864ed0d..ffd447506 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 @@ -451,7 +451,7 @@ 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, applicationContext.getEnvironment()); } }