Package software.amazon.awscdk.cfnpropertymixins.services.lambda

Class CfnEventSourceMappingPropsMixin

java.lang.Object
software.amazon.jsii.JsiiObject
software.amazon.awscdk.Mixin
software.amazon.awscdk.cfnpropertymixins.services.lambda.CfnEventSourceMappingPropsMixin
All Implemented Interfaces:
software.amazon.jsii.JsiiSerializable, software.constructs.IMixin
@Generated(value="jsii-pacmak/1.127.0 (build 2117ad5)", date="2026-03-11T13:20:00.900Z") @Stability(Stable) public class CfnEventSourceMappingPropsMixin extends Mixin implements software.constructs.IMixin
The AWS::Lambda::EventSourceMapping resource creates a mapping between an event source and an AWS Lambda function.

Lambda reads items from the event source and triggers the function.

For details about each event source type, see the following topics. In particular, each of the topics describes the required and optional parameters for the specific event source.

Example: 

 // The code below shows an example of how to instantiate this type.
 // The values are placeholders you should change.
 import software.amazon.awscdk.cfnpropertymixins.services.lambda.*;
 import software.amazon.awscdk.*;
 IMergeStrategy mergeStrategy;
 CfnEventSourceMappingPropsMixin cfnEventSourceMappingPropsMixin = CfnEventSourceMappingPropsMixin.Builder.create(CfnEventSourceMappingMixinProps.builder()
         .amazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfigProperty.builder()
                 .consumerGroupId("consumerGroupId")
                 .schemaRegistryConfig(SchemaRegistryConfigProperty.builder()
                         .accessConfigs(List.of(SchemaRegistryAccessConfigProperty.builder()
                                 .type("type")
                                 .uri("uri")
                                 .build()))
                         .eventRecordFormat("eventRecordFormat")
                         .schemaRegistryUri("schemaRegistryUri")
                         .schemaValidationConfigs(List.of(SchemaValidationConfigProperty.builder()
                                 .attribute("attribute")
                                 .build()))
                         .build())
                 .build())
         .batchSize(123)
         .bisectBatchOnFunctionError(false)
         .destinationConfig(DestinationConfigProperty.builder()
                 .onFailure(OnFailureProperty.builder()
                         .destination("destination")
                         .build())
                 .build())
         .documentDbEventSourceConfig(DocumentDBEventSourceConfigProperty.builder()
                 .collectionName("collectionName")
                 .databaseName("databaseName")
                 .fullDocument("fullDocument")
                 .build())
         .enabled(false)
         .eventSourceArn("eventSourceArn")
         .filterCriteria(FilterCriteriaProperty.builder()
                 .filters(List.of(FilterProperty.builder()
                         .pattern("pattern")
                         .build()))
                 .build())
         .functionName("functionName")
         .functionResponseTypes(List.of("functionResponseTypes"))
         .kmsKeyArn("kmsKeyArn")
         .loggingConfig(LoggingConfigProperty.builder()
                 .systemLogLevel("systemLogLevel")
                 .build())
         .maximumBatchingWindowInSeconds(123)
         .maximumRecordAgeInSeconds(123)
         .maximumRetryAttempts(123)
         .metricsConfig(MetricsConfigProperty.builder()
                 .metrics(List.of("metrics"))
                 .build())
         .parallelizationFactor(123)
         .provisionedPollerConfig(ProvisionedPollerConfigProperty.builder()
                 .maximumPollers(123)
                 .minimumPollers(123)
                 .pollerGroupName("pollerGroupName")
                 .build())
         .queues(List.of("queues"))
         .scalingConfig(ScalingConfigProperty.builder()
                 .maximumConcurrency(123)
                 .build())
         .selfManagedEventSource(SelfManagedEventSourceProperty.builder()
                 .endpoints(EndpointsProperty.builder()
                         .kafkaBootstrapServers(List.of("kafkaBootstrapServers"))
                         .build())
                 .build())
         .selfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfigProperty.builder()
                 .consumerGroupId("consumerGroupId")
                 .schemaRegistryConfig(SchemaRegistryConfigProperty.builder()
                         .accessConfigs(List.of(SchemaRegistryAccessConfigProperty.builder()
                                 .type("type")
                                 .uri("uri")
                                 .build()))
                         .eventRecordFormat("eventRecordFormat")
                         .schemaRegistryUri("schemaRegistryUri")
                         .schemaValidationConfigs(List.of(SchemaValidationConfigProperty.builder()
                                 .attribute("attribute")
                                 .build()))
                         .build())
                 .build())
         .sourceAccessConfigurations(List.of(SourceAccessConfigurationProperty.builder()
                 .type("type")
                 .uri("uri")
                 .build()))
         .startingPosition("startingPosition")
         .startingPositionTimestamp(123)
         .tags(List.of(CfnTag.builder()
                 .key("key")
                 .value("value")
                 .build()))
         .topics(List.of("topics"))
         .tumblingWindowInSeconds(123)
         .build())
 .strategy(mergeStrategy)
 .build();

See Also:

  • Field Details

    • CFN_PROPERTY_KEYS

      @Stability(Stable) protected static final List<String> CFN_PROPERTY_KEYS

  • Constructor Details

    • CfnEventSourceMappingPropsMixin

      protected CfnEventSourceMappingPropsMixin(software.amazon.jsii.JsiiObjectRef objRef)

    • CfnEventSourceMappingPropsMixin

      protected CfnEventSourceMappingPropsMixin(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

    • CfnEventSourceMappingPropsMixin

      @Stability(Stable) public CfnEventSourceMappingPropsMixin(@NotNull CfnEventSourceMappingMixinProps props, @Nullable CfnPropertyMixinOptions options)
      Create a mixin to apply properties to AWS::Lambda::EventSourceMapping.

      Parameters:
      props - L1 properties to apply. This parameter is required.
      options - Mixin options.

    • CfnEventSourceMappingPropsMixin

      @Stability(Stable) public CfnEventSourceMappingPropsMixin(@NotNull CfnEventSourceMappingMixinProps props)
      Create a mixin to apply properties to AWS::Lambda::EventSourceMapping.

      Parameters:
      props - L1 properties to apply. This parameter is required.

  • Method Details

    • applyTo

      @Stability(Stable) public void applyTo(@NotNull software.constructs.IConstruct construct)
      Apply the mixin properties to the construct.

      Specified by:
      applyTo in interface software.constructs.IMixin
      Specified by:
      applyTo in class Mixin
      Parameters:
      construct - This parameter is required.

    • supports

      @Stability(Stable) @NotNull public Boolean supports(@NotNull software.constructs.IConstruct construct)
      Check if this mixin supports the given construct.

      Specified by:
      supports in interface software.constructs.IMixin
      Overrides:
      supports in class Mixin
      Parameters:
      construct - This parameter is required.

    • getProps

      @Stability(Stable) @NotNull protected CfnEventSourceMappingMixinProps getProps()

    • getStrategy

      @Stability(Stable) @NotNull protected IMergeStrategy getStrategy()