diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/KotlinLambdaToFunctionAutoConfiguration.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/KotlinLambdaToFunctionAutoConfiguration.java index 034a6b883..5c8828e87 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/KotlinLambdaToFunctionAutoConfiguration.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/KotlinLambdaToFunctionAutoConfiguration.java @@ -123,7 +123,11 @@ public class KotlinLambdaToFunctionAutoConfiguration { if (this.kotlinLambdaTarget instanceof Function1) { return ((Function1) this.kotlinLambdaTarget).invoke(arg0); } - return ((Function) this.kotlinLambdaTarget).apply(arg0); + else if (this.kotlinLambdaTarget instanceof Function) { + return ((Function) this.kotlinLambdaTarget).apply(arg0); + } + ((Consumer) this.kotlinLambdaTarget).accept(arg0); + return null; } @Override