fix(lambda-event-sources): does not support setting maxRecordAge to infinity

packages/@aws-cdk-testing/framework-integ/test/aws-lambda-event-sources/test/integ.kinesis.js.snapshot/lambda-event-source-kinesis.template.json

@@ -99,6 +99,7 @@
     "FunctionName": {
      "Ref": "FC4345940"
     },
+    "MaximumRecordAgeInSeconds": -1,
     "StartingPosition": "TRIM_HORIZON",
     "TumblingWindowInSeconds": 60
    }

packages/@aws-cdk-testing/framework-integ/test/aws-lambda-event-sources/test/integ.kinesis.ts

@@ -13,6 +13,7 @@ class KinesisEventSourceTest extends cdk.Stack {
     const eventSource = new KinesisEventSource(stream, {
       startingPosition: lambda.StartingPosition.TRIM_HORIZON,
       tumblingWindow: cdk.Duration.seconds(60),
+      maxRecordAge: -1,
     });
 
     fn.addEventSource(eventSource);

packages/aws-cdk-lib/aws-lambda-event-sources/lib/stream.ts

@@ -58,13 +58,16 @@ export interface StreamEventSourceProps extends BaseStreamEventSourceProps {
 
   /**
    * The maximum age of a record that Lambda sends to a function for processing.
+   *
    * Valid Range:
    * * Minimum value of 60 seconds
    * * Maximum value of 7 days
    *
+   * Set to -1 if you want the Lambda function to never discard old records.
+   *
    * @default - the retention period configured on the stream
    */
-  readonly maxRecordAge?: Duration;
+  readonly maxRecordAge?: Duration | -1;
 
   /**
    * Maximum number of retry attempts

packages/aws-cdk-lib/aws-lambda-event-sources/test/kinesis.test.ts

@@ -307,4 +307,23 @@ describe('KinesisEventSource', () => {
       StartingPositionTimestamp: 1640995200,
     });
   });
+
+  test('infinite max record age', () => {
+    // GIVEN
+    const stack = new cdk.Stack();
+    const fn = new TestFunction(stack, 'Fn');
+    const stream = new kinesis.Stream(stack, 'S');
+    const eventSource = new sources.KinesisEventSource(stream, {
+      maxRecordAge: -1,
+      startingPosition: lambda.StartingPosition.TRIM_HORIZON,
+    });
+
+    // WHEN
+    fn.addEventSource(eventSource);
+
+    // THEN
+    Template.fromStack(stack).hasResourceProperties('AWS::Lambda::EventSourceMapping', {
+      MaximumRecordAgeInSeconds: -1,
+    });
+  });
 });

packages/aws-cdk-lib/aws-lambda/lib/event-source-mapping.ts

@@ -168,13 +168,17 @@ export interface EventSourceMappingOptions {
 
   /**
    * The maximum age of a record that Lambda sends to a function for processing.
+   *
    * Valid Range:
    * * Minimum value of 60 seconds
    * * Maximum value of 7 days
    *
+   * The default value is -1, which sets the maximum age to infinite.
+   * When the value is set to infinite, Lambda never discards old records.
+   *
    * @default - infinite or until the record expires.
    */
-  readonly maxRecordAge?: cdk.Duration;
+  readonly maxRecordAge?: cdk.Duration | -1;
 
   /**
    * The maximum number of times to retry when the function returns an error.
@@ -342,7 +346,11 @@ export class EventSourceMapping extends cdk.Resource implements IEventSourceMapp
       throw new Error('maxConcurrency must be between 2 and 1000 concurrent instances');
     }
 
-    if (props.maxRecordAge && (props.maxRecordAge.toSeconds() < 60 || props.maxRecordAge.toDays({ integral: false }) > 7)) {
+    if (
+      props.maxRecordAge &&
+      props.maxRecordAge !== -1 &&
+      (props.maxRecordAge.toSeconds() < 60 || props.maxRecordAge.toDays({ integral: false }) > 7)
+    ) {
       throw new Error('maxRecordAge must be between 60 seconds and 7 days inclusive');
     }
 
@@ -400,7 +408,7 @@ export class EventSourceMapping extends cdk.Resource implements IEventSourceMapp
       startingPositionTimestamp: props.startingPositionTimestamp,
       functionResponseTypes: props.reportBatchItemFailures ? ['ReportBatchItemFailures'] : undefined,
       maximumBatchingWindowInSeconds: props.maxBatchingWindow?.toSeconds(),
-      maximumRecordAgeInSeconds: props.maxRecordAge?.toSeconds(),
+      maximumRecordAgeInSeconds: props.maxRecordAge === -1 ? props.maxRecordAge : props.maxRecordAge?.toSeconds(),
       maximumRetryAttempts: props.retryAttempts,
       parallelizationFactor: props.parallelizationFactor,
       topics: props.kafkaTopic !== undefined ? [props.kafkaTopic] : undefined,

packages/aws-cdk-lib/aws-lambda/test/event-source-mapping.test.ts

@@ -1,7 +1,7 @@
 import { Match, Template } from '../../assertions';
 import * as cdk from '../../core';
 import * as lambda from '../lib';
-import { Code, EventSourceMapping, Function, Runtime, Alias, StartingPosition, FilterRule, FilterCriteria } from '../lib';
+import { Code, EventSourceMapping, Function, Alias, StartingPosition, FilterRule, FilterCriteria } from '../lib';
 
 let stack: cdk.Stack;
 let fn: Function;
@@ -415,4 +415,16 @@ describe('event source mapping', () => {
       startingPositionTimestamp: 1640995200,
     })).toThrow(/startingPositionTimestamp can only be used when startingPosition is AT_TIMESTAMP/);
   });
+
+  test('infinite max record age', () => {
+    new EventSourceMapping(stack, 'test', {
+      target: fn,
+      eventSourceArn: '',
+      maxRecordAge: -1,
+    });
+
+    Template.fromStack(stack).hasResourceProperties('AWS::Lambda::EventSourceMapping', {
+      MaximumRecordAgeInSeconds: -1,
+    });
+  });
 });