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()) {