From 7e53848e1a32be4624cc82e2afa15c925e40c57f Mon Sep 17 00:00:00 2001 From: Neokeld Date: Tue, 1 Nov 2022 21:28:50 +0100 Subject: [PATCH] functionRegistration cant be null Resolves #950 --- .../context/catalog/BeanFactoryAwareFunctionRegistry.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/BeanFactoryAwareFunctionRegistry.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/BeanFactoryAwareFunctionRegistry.java index b1e2e1fb2..7fe994759 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/BeanFactoryAwareFunctionRegistry.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/BeanFactoryAwareFunctionRegistry.java @@ -185,9 +185,7 @@ public class BeanFactoryAwareFunctionRegistry extends SimpleFunctionRegistry imp functionRegistration = new FunctionRegistration(functionCandidate, functionName).type(functionType); } // Certain Kafka Streams functions such as KStream[] return types could be null (esp when using Kotlin). - if (functionRegistration != null) { - this.register(functionRegistration); - } + this.register(functionRegistration); } else { if (logger.isDebugEnabled()) {