SCST-GH-2115 Ensure that in a case of KafkaNull we just return a payload

This commit is contained in:
Oleg Zhurakousky
2021-02-22 16:10:05 +01:00
parent 71c0d6d71e
commit c01b25f2fa

View File

@@ -855,7 +855,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
else if (input instanceof Message) {
if (((Message) input).getPayload().getClass().getName().equals("org.springframework.kafka.support.KafkaNull")
&& !this.isInputTypeMessage()) { //TODO rework
return null;
return ((Message) input).getPayload();
}
if (functionInvocationHelper != null) {