Package com.pulumi.aws.lambda

Class EventSourceMapping

  • public class EventSourceMapping
extends com.pulumi.resources.CustomResource
    Manages an AWS Lambda Event Source Mapping. Use this resource to connect Lambda functions to event sources like Kinesis, DynamoDB, SQS, Amazon MQ, and Managed Streaming for Apache Kafka (MSK). For information about Lambda and how to use it, see [What is AWS Lambda?](http://docs.aws.amazon.com/lambda/latest/dg/welcome.html). For information about event source mappings, see [CreateEventSourceMapping](http://docs.aws.amazon.com/lambda/latest/dg/API_CreateEventSourceMapping.html) in the API docs. ## Example Usage ### DynamoDB Stream 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.lambda.EventSourceMapping;
 import com.pulumi.aws.lambda.EventSourceMappingArgs;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new EventSourceMapping("example", EventSourceMappingArgs.builder()
             .eventSourceArn(exampleAwsDynamodbTable.streamArn())
             .functionName(exampleAwsLambdaFunction.arn())
             .startingPosition("LATEST")
             .tags(Map.of("Name", "dynamodb-stream-mapping"))
             .build());
 
     }
 }
    ### Kinesis Stream 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.lambda.EventSourceMapping;
 import com.pulumi.aws.lambda.EventSourceMappingArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingDestinationConfigArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingDestinationConfigOnFailureArgs;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new EventSourceMapping("example", EventSourceMappingArgs.builder()
             .destinationConfig(EventSourceMappingDestinationConfigArgs.builder()
                 .onFailure(EventSourceMappingDestinationConfigOnFailureArgs.builder()
                     .destinationArn(dlq.arn())
                     .build())
                 .build())
             .eventSourceArn(exampleAwsKinesisStream.arn())
             .functionName(exampleAwsLambdaFunction.arn())
             .startingPosition("LATEST")
             .batchSize(100)
             .maximumBatchingWindowInSeconds(5)
             .parallelizationFactor(2)
             .build());
 
     }
 }
    ### SQS Queue 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.lambda.EventSourceMapping;
 import com.pulumi.aws.lambda.EventSourceMappingArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingScalingConfigArgs;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new EventSourceMapping("example", EventSourceMappingArgs.builder()
             .scalingConfig(EventSourceMappingScalingConfigArgs.builder()
                 .maximumConcurrency(100)
                 .build())
             .eventSourceArn(exampleAwsSqsQueue.arn())
             .functionName(exampleAwsLambdaFunction.arn())
             .batchSize(10)
             .build());
 
     }
 }
    ### SQS with Event Filtering 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.lambda.EventSourceMapping;
 import com.pulumi.aws.lambda.EventSourceMappingArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingFilterCriteriaArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingFilterCriteriaFilterArgs;
 import static com.pulumi.codegen.internal.Serialization.*;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new EventSourceMapping("example", EventSourceMappingArgs.builder()
             .filterCriteria(EventSourceMappingFilterCriteriaArgs.builder()
                 .filters(EventSourceMappingFilterCriteriaFilterArgs.builder()
                     .pattern(serializeJson(
                         jsonObject(
                             jsonProperty("body", jsonObject(
                                 jsonProperty("Temperature", jsonArray(jsonObject(
                                     jsonProperty("numeric", jsonArray(
                                         ">", 
                                         0, 
                                         "<=", 
                                         100
                                     ))
                                 ))),
                                 jsonProperty("Location", jsonArray("New York"))
                             ))
                         )))
                     .build())
                 .build())
             .eventSourceArn(exampleAwsSqsQueue.arn())
             .functionName(exampleAwsLambdaFunction.arn())
             .build());
 
     }
 }
    ### Amazon MSK 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.lambda.EventSourceMapping;
 import com.pulumi.aws.lambda.EventSourceMappingArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new EventSourceMapping("example", EventSourceMappingArgs.builder()
             .amazonManagedKafkaEventSourceConfig(EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs.builder()
                 .consumerGroupId("lambda-consumer-group")
                 .build())
             .eventSourceArn(exampleAwsMskCluster.arn())
             .functionName(exampleAwsLambdaFunction.arn())
             .topics(            
                 "orders",
                 "inventory")
             .startingPosition("TRIM_HORIZON")
             .batchSize(100)
             .build());
 
     }
 }
    ### Self-Managed Apache Kafka 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.lambda.EventSourceMapping;
 import com.pulumi.aws.lambda.EventSourceMappingArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingSelfManagedEventSourceArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingSelfManagedKafkaEventSourceConfigArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingProvisionedPollerConfigArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingSourceAccessConfigurationArgs;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new EventSourceMapping("example", EventSourceMappingArgs.builder()
             .selfManagedEventSource(EventSourceMappingSelfManagedEventSourceArgs.builder()
                 .endpoints(Map.of("KAFKA_BOOTSTRAP_SERVERS", "kafka1.example.com:9092,kafka2.example.com:9092"))
                 .build())
             .selfManagedKafkaEventSourceConfig(EventSourceMappingSelfManagedKafkaEventSourceConfigArgs.builder()
                 .consumerGroupId("lambda-consumer-group")
                 .build())
             .provisionedPollerConfig(EventSourceMappingProvisionedPollerConfigArgs.builder()
                 .maximumPollers(100)
                 .minimumPollers(10)
                 .pollerGroupName("group-123")
                 .build())
             .sourceAccessConfigurations(            
                 EventSourceMappingSourceAccessConfigurationArgs.builder()
                     .type("VPC_SUBNET")
                     .uri(String.format("subnet:%s", example1.id()))
                     .build(),
                 EventSourceMappingSourceAccessConfigurationArgs.builder()
                     .type("VPC_SUBNET")
                     .uri(String.format("subnet:%s", example2.id()))
                     .build(),
                 EventSourceMappingSourceAccessConfigurationArgs.builder()
                     .type("VPC_SECURITY_GROUP")
                     .uri(String.format("security_group:%s", exampleAwsSecurityGroup.id()))
                     .build())
             .functionName(exampleAwsLambdaFunction.arn())
             .topics("orders")
             .startingPosition("TRIM_HORIZON")
             .build());
 
     }
 }
    ### Amazon MQ (ActiveMQ) 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.lambda.EventSourceMapping;
 import com.pulumi.aws.lambda.EventSourceMappingArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingSourceAccessConfigurationArgs;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new EventSourceMapping("example", EventSourceMappingArgs.builder()
             .sourceAccessConfigurations(EventSourceMappingSourceAccessConfigurationArgs.builder()
                 .type("BASIC_AUTH")
                 .uri(exampleAwsSecretsmanagerSecretVersion.arn())
                 .build())
             .eventSourceArn(exampleAwsMqBroker.arn())
             .functionName(exampleAwsLambdaFunction.arn())
             .queues("orders")
             .batchSize(10)
             .build());
 
     }
 }
    ### Amazon MQ (RabbitMQ) 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.lambda.EventSourceMapping;
 import com.pulumi.aws.lambda.EventSourceMappingArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingSourceAccessConfigurationArgs;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new EventSourceMapping("example", EventSourceMappingArgs.builder()
             .sourceAccessConfigurations(            
                 EventSourceMappingSourceAccessConfigurationArgs.builder()
                     .type("VIRTUAL_HOST")
                     .uri("/production")
                     .build(),
                 EventSourceMappingSourceAccessConfigurationArgs.builder()
                     .type("BASIC_AUTH")
                     .uri(exampleAwsSecretsmanagerSecretVersion.arn())
                     .build())
             .eventSourceArn(exampleAwsMqBroker.arn())
             .functionName(exampleAwsLambdaFunction.arn())
             .queues("orders")
             .batchSize(1)
             .build());
 
     }
 }
    ### DocumentDB Change Stream 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.lambda.EventSourceMapping;
 import com.pulumi.aws.lambda.EventSourceMappingArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingDocumentDbEventSourceConfigArgs;
 import com.pulumi.aws.lambda.inputs.EventSourceMappingSourceAccessConfigurationArgs;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new EventSourceMapping("example", EventSourceMappingArgs.builder()
             .documentDbEventSourceConfig(EventSourceMappingDocumentDbEventSourceConfigArgs.builder()
                 .databaseName("orders")
                 .collectionName("transactions")
                 .fullDocument("UpdateLookup")
                 .build())
             .sourceAccessConfigurations(EventSourceMappingSourceAccessConfigurationArgs.builder()
                 .type("BASIC_AUTH")
                 .uri(exampleAwsSecretsmanagerSecretVersion.arn())
                 .build())
             .eventSourceArn(exampleAwsDocdbCluster.arn())
             .functionName(exampleAwsLambdaFunction.arn())
             .startingPosition("LATEST")
             .build());
 
     }
 }
    ## Import ### Identity Schema #### Required * `uuid` (String) UUID of the event source mapping. #### Optional * `accountId` (String) AWS Account where this resource is managed. * `region` (String) Region where this resource is managed. Using `pulumi import`, import Lambda event source mappings using the `UUID` (event source mapping identifier). For example: ```sh $ pulumi import aws:lambda/eventSourceMapping:EventSourceMapping example 12345kxodurf3443 ```

    • Constructor Detail

      • EventSourceMapping

        public EventSourceMapping​(java.lang.String name)
        Parameters:
        name - The _unique_ name of the resulting resource.

      • EventSourceMapping

        public EventSourceMapping​(java.lang.String name,
                          EventSourceMappingArgs args)
        Parameters:
        name - The _unique_ name of the resulting resource.
        args - The arguments to use to populate this resource's properties.

      • EventSourceMapping

        public EventSourceMapping​(java.lang.String name,
                          EventSourceMappingArgs args,
                          @Nullable
                          com.pulumi.resources.CustomResourceOptions options)
        Parameters:
        name - The _unique_ name of the resulting resource.
        args - The arguments to use to populate this resource's properties.
        options - A bag of options that control this resource's behavior.

    • Method Detail

      • amazonManagedKafkaEventSourceConfig

        public com.pulumi.core.Output<EventSourceMappingAmazonManagedKafkaEventSourceConfig> amazonManagedKafkaEventSourceConfig()
        Returns:
        Additional configuration block for Amazon Managed Kafka sources. Incompatible with `selfManagedEventSource` and `selfManagedKafkaEventSourceConfig`. See below.

      • arn

        public com.pulumi.core.Output<java.lang.String> arn()
        Returns:
        Event source mapping ARN.

      • batchSize

        public com.pulumi.core.Output<java.util.Optional<java.lang.Integer>> batchSize()
        Returns:
        Largest number of records that Lambda will retrieve from your event source at the time of invocation. Defaults to `100` for DynamoDB, Kinesis, MQ and MSK, `10` for SQS.

      • bisectBatchOnFunctionError

        public com.pulumi.core.Output<java.util.Optional<java.lang.Boolean>> bisectBatchOnFunctionError()
        Returns:
        Whether to split the batch in two and retry if the function returns an error. Only available for stream sources (DynamoDB and Kinesis). Defaults to `false`.

      • destinationConfig

        public com.pulumi.core.Output<java.util.Optional<EventSourceMappingDestinationConfig>> destinationConfig()
        Returns:
        Amazon SQS queue, Amazon SNS topic or Amazon S3 bucket (only available for Kafka sources) destination for failed records. Only available for stream sources (DynamoDB and Kinesis) and Kafka sources (Amazon MSK and Self-managed Apache Kafka). See below.

      • documentDbEventSourceConfig

        public com.pulumi.core.Output<java.util.Optional<EventSourceMappingDocumentDbEventSourceConfig>> documentDbEventSourceConfig()
        Returns:
        Configuration settings for a DocumentDB event source. See below.

      • enabled

        public com.pulumi.core.Output<java.util.Optional<java.lang.Boolean>> enabled()
        Returns:
        Whether the mapping is enabled. Defaults to `true`.

      • eventSourceArn

        public com.pulumi.core.Output<java.util.Optional<java.lang.String>> eventSourceArn()
        Returns:
        Event source ARN - required for Kinesis stream, DynamoDB stream, SQS queue, MQ broker, MSK cluster or DocumentDB change stream. Incompatible with Self Managed Kafka source.

      • filterCriteria

        public com.pulumi.core.Output<java.util.Optional<EventSourceMappingFilterCriteria>> filterCriteria()
        Returns:
        Criteria to use for [event filtering](https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html) Kinesis stream, DynamoDB stream, SQS queue event sources. See below.

      • functionArn

        public com.pulumi.core.Output<java.lang.String> functionArn()
        Returns:
        ARN of the Lambda function the event source mapping is sending events to. (Note: this is a computed value that differs from `functionName` above.)

      • functionName

        public com.pulumi.core.Output<java.lang.String> functionName()
        Returns:
        Name or ARN of the Lambda function that will be subscribing to events. The following arguments are optional:

      • functionResponseTypes

        public com.pulumi.core.Output<java.util.Optional<java.util.List<java.lang.String>>> functionResponseTypes()
        Returns:
        List of current response type enums applied to the event source mapping for [AWS Lambda checkpointing](https://docs.aws.amazon.com/lambda/latest/dg/with-ddb.html#services-ddb-batchfailurereporting). Only available for SQS and stream sources (DynamoDB and Kinesis). Valid values: `ReportBatchItemFailures`.

      • kmsKeyArn

        public com.pulumi.core.Output<java.util.Optional<java.lang.String>> kmsKeyArn()
        Returns:
        ARN of the KMS customer managed key that Lambda uses to encrypt your function's filter criteria.

      • lastModified

        public com.pulumi.core.Output<java.lang.String> lastModified()
        Returns:
        Date this resource was last modified.

      • lastProcessingResult

        public com.pulumi.core.Output<java.lang.String> lastProcessingResult()
        Returns:
        Result of the last AWS Lambda invocation of your Lambda function.

      • maximumBatchingWindowInSeconds

        public com.pulumi.core.Output<java.util.Optional<java.lang.Integer>> maximumBatchingWindowInSeconds()
        Returns:
        Maximum amount of time to gather records before invoking the function, in seconds (between 0 and 300). Records will continue to buffer until either `maximumBatchingWindowInSeconds` expires or `batchSize` has been met. For streaming event sources, defaults to as soon as records are available in the stream. Only available for stream sources (DynamoDB and Kinesis) and SQS standard queues.

      • maximumRecordAgeInSeconds

        public com.pulumi.core.Output<java.lang.Integer> maximumRecordAgeInSeconds()
        Returns:
        Maximum age of a record that Lambda sends to a function for processing. Only available for stream sources (DynamoDB and Kinesis). Must be either -1 (forever, and the default value) or between 60 and 604800 (inclusive).

      • maximumRetryAttempts

        public com.pulumi.core.Output<java.lang.Integer> maximumRetryAttempts()
        Returns:
        Maximum number of times to retry when the function returns an error. Only available for stream sources (DynamoDB and Kinesis). Minimum and default of -1 (forever), maximum of 10000.

      • metricsConfig

        public com.pulumi.core.Output<java.util.Optional<EventSourceMappingMetricsConfig>> metricsConfig()
        Returns:
        CloudWatch metrics configuration of the event source. Only available for stream sources (DynamoDB and Kinesis) and SQS queues. See below.

      • parallelizationFactor

        public com.pulumi.core.Output<java.lang.Integer> parallelizationFactor()
        Returns:
        Number of batches to process from each shard concurrently. Only available for stream sources (DynamoDB and Kinesis). Minimum and default of 1, maximum of 10.

      • provisionedPollerConfig

        public com.pulumi.core.Output<java.util.Optional<EventSourceMappingProvisionedPollerConfig>> provisionedPollerConfig()
        Returns:
        Event poller configuration for the event source. Only valid for Amazon MSK or self-managed Apache Kafka sources. See below.

      • queues

        public com.pulumi.core.Output<java.util.Optional<java.lang.String>> queues()
        Returns:
        Name of the Amazon MQ broker destination queue to consume. Only available for MQ sources. The list must contain exactly one queue name.

      • region

        public com.pulumi.core.Output<java.lang.String> region()
        Returns:
        Region where this resource will be [managed](https://docs.aws.amazon.com/general/latest/gr/rande.html#regional-endpoints). Defaults to the Region set in the provider configuration.

      • scalingConfig

        public com.pulumi.core.Output<java.util.Optional<EventSourceMappingScalingConfig>> scalingConfig()
        Returns:
        Scaling configuration of the event source. Only available for SQS queues. See below.

      • selfManagedEventSource

        public com.pulumi.core.Output<java.util.Optional<EventSourceMappingSelfManagedEventSource>> selfManagedEventSource()
        Returns:
        For Self Managed Kafka sources, the location of the self managed cluster. If set, configuration must also include `sourceAccessConfiguration`. See below.

      • selfManagedKafkaEventSourceConfig

        public com.pulumi.core.Output<EventSourceMappingSelfManagedKafkaEventSourceConfig> selfManagedKafkaEventSourceConfig()
        Returns:
        Additional configuration block for Self Managed Kafka sources. Incompatible with `eventSourceArn` and `amazonManagedKafkaEventSourceConfig`. See below.

      • sourceAccessConfigurations

        public com.pulumi.core.Output<java.util.Optional<java.util.List<EventSourceMappingSourceAccessConfiguration>>> sourceAccessConfigurations()
        Returns:
        For Self Managed Kafka sources, the access configuration for the source. If set, configuration must also include `selfManagedEventSource`. See below.

      • startingPosition

        public com.pulumi.core.Output<java.util.Optional<java.lang.String>> startingPosition()
        Returns:
        Position in the stream where AWS Lambda should start reading. Must be one of `AT_TIMESTAMP` (Kinesis only), `LATEST` or `TRIM_HORIZON` if getting events from Kinesis, DynamoDB, MSK or Self Managed Apache Kafka. Must not be provided if getting events from SQS. More information about these positions can be found in the [AWS DynamoDB Streams API Reference](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_streams_GetShardIterator.html) and [AWS Kinesis API Reference](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html#Kinesis-GetShardIterator-request-ShardIteratorType).

      • startingPositionTimestamp

        public com.pulumi.core.Output<java.util.Optional<java.lang.String>> startingPositionTimestamp()
        Returns:
        Timestamp in [RFC3339 format](https://tools.ietf.org/html/rfc3339#section-5.8) of the data record which to start reading when using `startingPosition` set to `AT_TIMESTAMP`. If a record with this exact timestamp does not exist, the next later record is chosen. If the timestamp is older than the current trim horizon, the oldest available record is chosen.

      • state

        public com.pulumi.core.Output<java.lang.String> state()
        Returns:
        State of the event source mapping.

      • stateTransitionReason

        public com.pulumi.core.Output<java.lang.String> stateTransitionReason()
        Returns:
        Reason the event source mapping is in its current state.

      • tags

        public com.pulumi.core.Output<java.util.Optional<java.util.Map<java.lang.String,​java.lang.String>>> tags()
        Returns:
        Map of tags to assign to the object. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

      • tagsAll

        public com.pulumi.core.Output<java.util.Map<java.lang.String,​java.lang.String>> tagsAll()
        Returns:
        Map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

      • topics

        public com.pulumi.core.Output<java.util.Optional<java.util.List<java.lang.String>>> topics()
        Returns:
        Name of the Kafka topics. Only available for MSK sources. A single topic name must be specified.

      • tumblingWindowInSeconds

        public com.pulumi.core.Output<java.util.Optional<java.lang.Integer>> tumblingWindowInSeconds()
        Returns:
        Duration in seconds of a processing window for [AWS Lambda streaming analytics](https://docs.aws.amazon.com/lambda/latest/dg/with-kinesis.html#services-kinesis-windows). The range is between 1 second up to 900 seconds. Only available for stream sources (DynamoDB and Kinesis).

      • useResourceTimeoutForPropagation

        public com.pulumi.core.Output<java.util.Optional<java.lang.Boolean>> useResourceTimeoutForPropagation()
        Returns:
        Whether to apply resource level timeout values while retrying eventually consistent API operations. By default the provider uses a 5 minute timeout to allow for propagation in the Lambda service. When set to `true`, this default value is replaced with the configurable resource timeouts. Increased timeout values may be useful in highly active accounts, or regions where propagation delays are inconsistent.

      • uuid

        public com.pulumi.core.Output<java.lang.String> uuid()
        Returns:
        UUID of the created event source mapping.

      • get

        public static EventSourceMapping get​(java.lang.String name,
                                     com.pulumi.core.Output<java.lang.String> id,
                                     @Nullable
                                     EventSourceMappingState state,
                                     @Nullable
                                     com.pulumi.resources.CustomResourceOptions options)
        Get an existing Host resource's state with the given name, ID, and optional extra properties used to qualify the lookup.
        Parameters:
        name - The _unique_ name of the resulting resource.
        id - The _unique_ provider ID of the resource to lookup.
        state -
        options - Optional settings to control the behavior of the CustomResource.