functionRegistration cant be null

Resolves #950
This commit is contained in:
Neokeld
2022-11-01 21:28:50 +01:00
committed by Oleg Zhurakousky
parent 3c0a7fbc19
commit acf86d53bd

View File

@@ -170,9 +170,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()) {