Package software.amazon.awscdk.services.lambda

Interface EventSourceMappingProps

All Superinterfaces:
EventSourceMappingOptions, software.amazon.jsii.JsiiSerializable
All Known Implementing Classes:
EventSourceMappingProps.Jsii$Proxy
@Generated(value="jsii-pacmak/1.119.0 (build 1634eac)", date="2025-11-20T23:37:24.319Z") @Stability(Stable) public interface EventSourceMappingProps extends software.amazon.jsii.JsiiSerializable, EventSourceMappingOptions
Properties for declaring a new event source mapping.

Example: 

 // The code below shows an example of how to instantiate this type.
 // The values are placeholders you should change.
 import software.amazon.awscdk.*;
 import software.amazon.awscdk.services.kms.*;
 import software.amazon.awscdk.services.lambda.*;
 IEventSourceDlq eventSourceDlq;
 Object filters;
 Function function_;
 Key key;
 ISchemaRegistry schemaRegistry;
 SourceAccessConfigurationType sourceAccessConfigurationType;
 EventSourceMappingProps eventSourceMappingProps = EventSourceMappingProps.builder()
         .target(function_)
         // the properties below are optional
         .batchSize(123)
         .bisectBatchOnError(false)
         .enabled(false)
         .eventSourceArn("eventSourceArn")
         .filterEncryption(key)
         .filters(List.of(Map.of(
                 "filtersKey", filters)))
         .kafkaBootstrapServers(List.of("kafkaBootstrapServers"))
         .kafkaConsumerGroupId("kafkaConsumerGroupId")
         .kafkaTopic("kafkaTopic")
         .maxBatchingWindow(Duration.minutes(30))
         .maxConcurrency(123)
         .maxRecordAge(Duration.minutes(30))
         .metricsConfig(MetricsConfig.builder()
                 .metrics(List.of(MetricType.EVENT_COUNT))
                 .build())
         .onFailure(eventSourceDlq)
         .parallelizationFactor(123)
         .provisionedPollerConfig(ProvisionedPollerConfig.builder()
                 .maximumPollers(123)
                 .minimumPollers(123)
                 .build())
         .reportBatchItemFailures(false)
         .retryAttempts(123)
         .schemaRegistryConfig(schemaRegistry)
         .sourceAccessConfigurations(List.of(SourceAccessConfiguration.builder()
                 .type(sourceAccessConfigurationType)
                 .uri("uri")
                 .build()))
         .startingPosition(StartingPosition.TRIM_HORIZON)
         .startingPositionTimestamp(123)
         .supportS3OnFailureDestination(false)
         .tumblingWindow(Duration.minutes(30))
         .build();