committed by
Oleg Zhurakousky
parent
8983369a4d
commit
7e53848e1a
@@ -185,9 +185,7 @@ public class BeanFactoryAwareFunctionRegistry extends SimpleFunctionRegistry imp
|
|||||||
functionRegistration = new FunctionRegistration(functionCandidate, functionName).type(functionType);
|
functionRegistration = new FunctionRegistration(functionCandidate, functionName).type(functionType);
|
||||||
}
|
}
|
||||||
// Certain Kafka Streams functions such as KStream[] return types could be null (esp when using Kotlin).
|
// 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 {
|
else {
|
||||||
if (logger.isDebugEnabled()) {
|
if (logger.isDebugEnabled()) {
|
||||||
|
|||||||
Reference in New Issue
Block a user