diff --git a/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/AWSLambdaUtils.java b/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/AWSLambdaUtils.java index 5fd4dda97..35dd5a537 100644 --- a/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/AWSLambdaUtils.java +++ b/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/AWSLambdaUtils.java @@ -121,7 +121,7 @@ final class AWSLambdaUtils { logger.info("Incoming request is API Gateway v2.0"); messageBuilder = createMessageBuilderForPOJOFunction(objectMapper, (Map) request); } - Object providedHeaders = ((Map) request).remove("headers"); + Object providedHeaders = ((Map) request).get("headers"); if (providedHeaders != null && providedHeaders instanceof Map) { messageBuilder = MessageBuilder.withPayload(request); messageBuilder.removeHeader("headers");