SCST-GH-2115 Ensure that in a case of KafkaNull we just return a payload
This commit is contained in:
@@ -842,7 +842,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
|
||||
}
|
||||
else if (!FunctionTypeUtils.isMessage(type)) {
|
||||
if (this.payloadIsSpecialType(((Message<?>) value).getPayload())) {
|
||||
return null;
|
||||
return ((Message<?>) value).getPayload();
|
||||
}
|
||||
if (!((Message<?>) convertedValue).getHeaders().containsKey("scf-sink-url")) {
|
||||
convertedValue = ((Message<?>) convertedValue).getPayload();
|
||||
|
||||
Reference in New Issue
Block a user