From 531c071d6f065362a67c47f06a26b61648c2df3d Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Wed, 30 Aug 2023 12:33:03 -0400 Subject: [PATCH] GH-1060 Fix KafkaNull regression issue 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 --- .../function/context/catalog/SimpleFunctionRegistry.java | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java index a5398b5f2..e470d1b5e 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java @@ -1021,13 +1021,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry { } else { Object extractedValue = this.extractValueFromOriginalValueHolderIfNecessary(convertedInput); - if (extractedValue instanceof Message && - ((Message) extractedValue).getPayload().getClass().getName().equals("org.springframework.kafka.support.KafkaNull")) { - ((Consumer) this.target).accept(null); - } - else { - ((Consumer) this.target).accept(extractedValue); - } + ((Consumer) this.target).accept(extractedValue); } return result; }