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 c68c17108..115576b4d 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 @@ -711,6 +711,10 @@ public class FunctionConfiguration { functionBindableProxyDefinition.getConstructorArgumentValues().addGenericArgumentValue(this.streamFunctionProperties); registry.registerBeanDefinition(functionDefinition + "_binding", functionBindableProxyDefinition); } + else { + throw new IllegalArgumentException("The function definition '" + streamFunctionProperties.getDefinition() + + "' is not valid. The referenced function bean or one of its components does not exist"); + } } }