SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-1060 Fix KafkaNull regression issue

Browse Source 
Fixing a KafkaNull related regression issue where consumers
receive null values for payload erasing any headers completely.

Resolves https://github.com/spring-cloud/spring-cloud-function/issues/1060
This commit is contained in:
Soby Chacko
2023-08-30 12:33:03 -04:00
parent 7db99087a5
commit 19d1f320de
1 changed files with 1 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
View File

@@ -1033,13 +1033,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry {
} }
else { else {
Object extractedValue = this.extractValueFromOriginalValueHolderIfNecessary(convertedInput); Object extractedValue = this.extractValueFromOriginalValueHolderIfNecessary(convertedInput);
if (extractedValue instanceof Message && ((Consumer) this.target).accept(extractedValue);
((Message) extractedValue).getPayload().getClass().getName().equals("org.springframework.kafka.support.KafkaNull")) {
((Consumer) this.target).accept(null);
}
else {
((Consumer) this.target).accept(extractedValue);
}
} }
return result; return result;
} }