1. Packages
  2. AWS Cloud Control
  3. API Docs
  4. lambda
  5. EventSourceMapping

We recommend new projects start with resources from the AWS provider.

AWS Cloud Control v1.37.0 published on Wednesday, Oct 15, 2025 by Pulumi
pulumi/pulumi-aws-native

aws-native.lambda.EventSourceMapping

Get Started
aws-native logo

We recommend new projects start with resources from the AWS provider.

AWS Cloud Control v1.37.0 published on Wednesday, Oct 15, 2025 by Pulumi
pulumi/pulumi-aws-native

    The AWS::Lambda::EventSourceMapping resource creates a mapping between an event source and an LAMlong function. LAM 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.

    Create EventSourceMapping Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new EventSourceMapping(name: string, args: EventSourceMappingArgs, opts?: CustomResourceOptions);
    @overload
def EventSourceMapping(resource_name: str,
                       args: EventSourceMappingArgs,
                       opts: Optional[ResourceOptions] = None)

@overload
def EventSourceMapping(resource_name: str,
                       opts: Optional[ResourceOptions] = None,
                       function_name: Optional[str] = None,
                       maximum_record_age_in_seconds: Optional[int] = None,
                       starting_position_timestamp: Optional[float] = None,
                       destination_config: Optional[EventSourceMappingDestinationConfigArgs] = None,
                       document_db_event_source_config: Optional[EventSourceMappingDocumentDbEventSourceConfigArgs] = None,
                       enabled: Optional[bool] = None,
                       event_source_arn: Optional[str] = None,
                       filter_criteria: Optional[EventSourceMappingFilterCriteriaArgs] = None,
                       batch_size: Optional[int] = None,
                       function_response_types: Optional[Sequence[EventSourceMappingFunctionResponseTypesItem]] = None,
                       kms_key_arn: Optional[str] = None,
                       maximum_batching_window_in_seconds: Optional[int] = None,
                       amazon_managed_kafka_event_source_config: Optional[EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs] = None,
                       bisect_batch_on_function_error: Optional[bool] = None,
                       maximum_retry_attempts: Optional[int] = None,
                       self_managed_event_source: Optional[EventSourceMappingSelfManagedEventSourceArgs] = None,
                       provisioned_poller_config: Optional[EventSourceMappingProvisionedPollerConfigArgs] = None,
                       queues: Optional[Sequence[str]] = None,
                       scaling_config: Optional[EventSourceMappingScalingConfigArgs] = None,
                       parallelization_factor: Optional[int] = None,
                       self_managed_kafka_event_source_config: Optional[EventSourceMappingSelfManagedKafkaEventSourceConfigArgs] = None,
                       source_access_configurations: Optional[Sequence[EventSourceMappingSourceAccessConfigurationArgs]] = None,
                       starting_position: Optional[str] = None,
                       metrics_config: Optional[EventSourceMappingMetricsConfigArgs] = None,
                       tags: Optional[Sequence[_root_inputs.TagArgs]] = None,
                       topics: Optional[Sequence[str]] = None,
                       tumbling_window_in_seconds: Optional[int] = None)
    func NewEventSourceMapping(ctx *Context, name string, args EventSourceMappingArgs, opts ...ResourceOption) (*EventSourceMapping, error)
    public EventSourceMapping(string name, EventSourceMappingArgs args, CustomResourceOptions? opts = null)
    public EventSourceMapping(String name, EventSourceMappingArgs args)
public EventSourceMapping(String name, EventSourceMappingArgs args, CustomResourceOptions options)

    type: aws-native:lambda:EventSourceMapping
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

    Parameters

    name string
    The unique name of the resource.
    args EventSourceMappingArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    resource_name str
    The unique name of the resource.
    args EventSourceMappingArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control resource's behavior.
    ctx Context
    Context object for the current deployment.
    name string
    The unique name of the resource.
    args EventSourceMappingArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args EventSourceMappingArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args EventSourceMappingArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    EventSourceMapping Resource Properties

    To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

    Inputs

    In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

    The EventSourceMapping resource accepts the following input properties:

    FunctionName string

    The name or ARN of the Lambda function. Name formats

    • Function name – MyFunction.
    • Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
    • Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
    • Partial ARN – 123456789012:function:MyFunction.

    The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 characters in length.

    AmazonManagedKafkaEventSourceConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingAmazonManagedKafkaEventSourceConfig
    Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source.
    BatchSize int
    The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation (6 MB).

    • Amazon Kinesis – Default 100. Max 10,000.
    • Amazon DynamoDB Streams – Default 100. Max 10,000.
    • Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues the max is 10.
    • Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000.
    • Self-managed Apache Kafka – Default 100. Max 10,000.
    • Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000.
    • DocumentDB – Default 100. Max 10,000.
    BisectBatchOnFunctionError bool
    (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. The default value is false. When using BisectBatchOnFunctionError, check the BatchSize parameter in the OnFailure destination message's metadata. The BatchSize could be greater than 1 since LAM consolidates failed messages metadata when writing to the OnFailure destination.
    DestinationConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingDestinationConfig
    (Kinesis, DynamoDB Streams, Amazon MSK, and self-managed Apache Kafka event sources only) A configuration object that specifies the destination of an event after Lambda processes it.
    DocumentDbEventSourceConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingDocumentDbEventSourceConfig
    Specific configuration settings for a DocumentDB event source.
    Enabled bool
    When true, the event source mapping is active. When false, Lambda pauses polling and invocation. Default: True
    EventSourceArn string
    The Amazon Resource Name (ARN) of the event source.

    • Amazon Kinesis – The ARN of the data stream or a stream consumer.
    • Amazon DynamoDB Streams – The ARN of the stream.
    • Amazon Simple Queue Service – The ARN of the queue.
    • Amazon Managed Streaming for Apache Kafka – The ARN of the cluster or the ARN of the VPC connection (for cross-account event source mappings).
    • Amazon MQ – The ARN of the broker.
    • Amazon DocumentDB – The ARN of the DocumentDB change stream.
    FilterCriteria Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingFilterCriteria
    An object that defines the filter criteria that determine whether Lambda should process an event. For more information, see Lambda event filtering.
    FunctionResponseTypes List<Pulumi.AwsNative.Lambda.EventSourceMappingFunctionResponseTypesItem>
    (Kinesis, DynamoDB Streams, and SQS) A list of current response type enums applied to the event source mapping. Valid Values: ReportBatchItemFailures
    KmsKeyArn string
    The ARN of the KMSlong (KMS) customer managed key that Lambda uses to encrypt your function's filter criteria.
    MaximumBatchingWindowInSeconds int
    The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. Default (, , event sources): 0 Default (, Kafka, , event sources): 500 ms Related setting: For SQS event sources, when you set BatchSize to a value greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
    MaximumRecordAgeInSeconds int
    (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, Lambda never discards old records. The minimum valid value for maximum record age is 60s. Although values less than 60 and greater than -1 fall within the parameter's absolute range, they are not allowed
    MaximumRetryAttempts int
    (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, Lambda retries failed records until the record expires in the event source.
    MetricsConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingMetricsConfig
    The metrics configuration for your event source. For more information, see Event source mapping metrics.
    ParallelizationFactor int
    (Kinesis and DynamoDB Streams only) The number of batches to process concurrently from each shard. The default value is 1.
    ProvisionedPollerConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingProvisionedPollerConfig
    (Amazon MSK and self-managed Apache Kafka only) The provisioned mode configuration for the event source. For more information, see provisioned mode.
    Queues List<string>
    (Amazon MQ) The name of the Amazon MQ broker destination queue to consume.
    ScalingConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingScalingConfig
    (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum concurrency for Amazon SQS event sources.
    SelfManagedEventSource Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingSelfManagedEventSource
    The self-managed Apache Kafka cluster for your event source.
    SelfManagedKafkaEventSourceConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingSelfManagedKafkaEventSourceConfig
    Specific configuration settings for a self-managed Apache Kafka event source.
    SourceAccessConfigurations List<Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingSourceAccessConfiguration>
    An array of the authentication protocol, VPC components, or virtual host to secure and define your event source.
    StartingPosition string
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB.

    • LATEST - Read only new records.
    • TRIM_HORIZON - Process all available records.
    • AT_TIMESTAMP - Specify a time from which to start reading records.
    StartingPositionTimestamp double
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds. StartingPositionTimestamp cannot be in the future.
    Tags List<Pulumi.AwsNative.Inputs.Tag>
    A list of tags to add to the event source mapping. You must have the lambda:TagResource, lambda:UntagResource, and lambda:ListTags permissions for your principal to manage the CFN stack. If you don't have these permissions, there might be unexpected behavior with stack-level tags propagating to the resource during resource creation and update.
    Topics List<string>
    The name of the Kafka topic.
    TumblingWindowInSeconds int
    (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis Streams event sources. A value of 0 seconds indicates no tumbling window.
    FunctionName string

    The name or ARN of the Lambda function. Name formats

    • Function name – MyFunction.
    • Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
    • Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
    • Partial ARN – 123456789012:function:MyFunction.

    The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 characters in length.

    AmazonManagedKafkaEventSourceConfig EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs
    Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source.
    BatchSize int
    The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation (6 MB).

    • Amazon Kinesis – Default 100. Max 10,000.
    • Amazon DynamoDB Streams – Default 100. Max 10,000.
    • Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues the max is 10.
    • Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000.
    • Self-managed Apache Kafka – Default 100. Max 10,000.
    • Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000.
    • DocumentDB – Default 100. Max 10,000.
    BisectBatchOnFunctionError bool
    (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. The default value is false. When using BisectBatchOnFunctionError, check the BatchSize parameter in the OnFailure destination message's metadata. The BatchSize could be greater than 1 since LAM consolidates failed messages metadata when writing to the OnFailure destination.
    DestinationConfig EventSourceMappingDestinationConfigArgs
    (Kinesis, DynamoDB Streams, Amazon MSK, and self-managed Apache Kafka event sources only) A configuration object that specifies the destination of an event after Lambda processes it.
    DocumentDbEventSourceConfig EventSourceMappingDocumentDbEventSourceConfigArgs
    Specific configuration settings for a DocumentDB event source.
    Enabled bool
    When true, the event source mapping is active. When false, Lambda pauses polling and invocation. Default: True
    EventSourceArn string
    The Amazon Resource Name (ARN) of the event source.

    • Amazon Kinesis – The ARN of the data stream or a stream consumer.
    • Amazon DynamoDB Streams – The ARN of the stream.
    • Amazon Simple Queue Service – The ARN of the queue.
    • Amazon Managed Streaming for Apache Kafka – The ARN of the cluster or the ARN of the VPC connection (for cross-account event source mappings).
    • Amazon MQ – The ARN of the broker.
    • Amazon DocumentDB – The ARN of the DocumentDB change stream.
    FilterCriteria EventSourceMappingFilterCriteriaArgs
    An object that defines the filter criteria that determine whether Lambda should process an event. For more information, see Lambda event filtering.
    FunctionResponseTypes []EventSourceMappingFunctionResponseTypesItem
    (Kinesis, DynamoDB Streams, and SQS) A list of current response type enums applied to the event source mapping. Valid Values: ReportBatchItemFailures
    KmsKeyArn string
    The ARN of the KMSlong (KMS) customer managed key that Lambda uses to encrypt your function's filter criteria.
    MaximumBatchingWindowInSeconds int
    The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. Default (, , event sources): 0 Default (, Kafka, , event sources): 500 ms Related setting: For SQS event sources, when you set BatchSize to a value greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
    MaximumRecordAgeInSeconds int
    (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, Lambda never discards old records. The minimum valid value for maximum record age is 60s. Although values less than 60 and greater than -1 fall within the parameter's absolute range, they are not allowed
    MaximumRetryAttempts int
    (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, Lambda retries failed records until the record expires in the event source.
    MetricsConfig EventSourceMappingMetricsConfigArgs
    The metrics configuration for your event source. For more information, see Event source mapping metrics.
    ParallelizationFactor int
    (Kinesis and DynamoDB Streams only) The number of batches to process concurrently from each shard. The default value is 1.
    ProvisionedPollerConfig EventSourceMappingProvisionedPollerConfigArgs
    (Amazon MSK and self-managed Apache Kafka only) The provisioned mode configuration for the event source. For more information, see provisioned mode.
    Queues []string
    (Amazon MQ) The name of the Amazon MQ broker destination queue to consume.
    ScalingConfig EventSourceMappingScalingConfigArgs
    (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum concurrency for Amazon SQS event sources.
    SelfManagedEventSource EventSourceMappingSelfManagedEventSourceArgs
    The self-managed Apache Kafka cluster for your event source.
    SelfManagedKafkaEventSourceConfig EventSourceMappingSelfManagedKafkaEventSourceConfigArgs
    Specific configuration settings for a self-managed Apache Kafka event source.
    SourceAccessConfigurations []EventSourceMappingSourceAccessConfigurationArgs
    An array of the authentication protocol, VPC components, or virtual host to secure and define your event source.
    StartingPosition string
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB.

    • LATEST - Read only new records.
    • TRIM_HORIZON - Process all available records.
    • AT_TIMESTAMP - Specify a time from which to start reading records.
    StartingPositionTimestamp float64
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds. StartingPositionTimestamp cannot be in the future.
    Tags TagArgs
    A list of tags to add to the event source mapping. You must have the lambda:TagResource, lambda:UntagResource, and lambda:ListTags permissions for your principal to manage the CFN stack. If you don't have these permissions, there might be unexpected behavior with stack-level tags propagating to the resource during resource creation and update.
    Topics []string
    The name of the Kafka topic.
    TumblingWindowInSeconds int
    (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis Streams event sources. A value of 0 seconds indicates no tumbling window.
    functionName String

    The name or ARN of the Lambda function. Name formats

    • Function name – MyFunction.
    • Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
    • Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
    • Partial ARN – 123456789012:function:MyFunction.

    The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 characters in length.

    amazonManagedKafkaEventSourceConfig EventSourceMappingAmazonManagedKafkaEventSourceConfig
    Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source.
    batchSize Integer
    The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation (6 MB).

    • Amazon Kinesis – Default 100. Max 10,000.
    • Amazon DynamoDB Streams – Default 100. Max 10,000.
    • Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues the max is 10.
    • Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000.
    • Self-managed Apache Kafka – Default 100. Max 10,000.
    • Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000.
    • DocumentDB – Default 100. Max 10,000.
    bisectBatchOnFunctionError Boolean
    (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. The default value is false. When using BisectBatchOnFunctionError, check the BatchSize parameter in the OnFailure destination message's metadata. The BatchSize could be greater than 1 since LAM consolidates failed messages metadata when writing to the OnFailure destination.
    destinationConfig EventSourceMappingDestinationConfig
    (Kinesis, DynamoDB Streams, Amazon MSK, and self-managed Apache Kafka event sources only) A configuration object that specifies the destination of an event after Lambda processes it.
    documentDbEventSourceConfig EventSourceMappingDocumentDbEventSourceConfig
    Specific configuration settings for a DocumentDB event source.
    enabled Boolean
    When true, the event source mapping is active. When false, Lambda pauses polling and invocation. Default: True
    eventSourceArn String
    The Amazon Resource Name (ARN) of the event source.

    • Amazon Kinesis – The ARN of the data stream or a stream consumer.
    • Amazon DynamoDB Streams – The ARN of the stream.
    • Amazon Simple Queue Service – The ARN of the queue.
    • Amazon Managed Streaming for Apache Kafka – The ARN of the cluster or the ARN of the VPC connection (for cross-account event source mappings).
    • Amazon MQ – The ARN of the broker.
    • Amazon DocumentDB – The ARN of the DocumentDB change stream.
    filterCriteria EventSourceMappingFilterCriteria
    An object that defines the filter criteria that determine whether Lambda should process an event. For more information, see Lambda event filtering.
    functionResponseTypes List<EventSourceMappingFunctionResponseTypesItem>
    (Kinesis, DynamoDB Streams, and SQS) A list of current response type enums applied to the event source mapping. Valid Values: ReportBatchItemFailures
    kmsKeyArn String
    The ARN of the KMSlong (KMS) customer managed key that Lambda uses to encrypt your function's filter criteria.
    maximumBatchingWindowInSeconds Integer
    The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. Default (, , event sources): 0 Default (, Kafka, , event sources): 500 ms Related setting: For SQS event sources, when you set BatchSize to a value greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
    maximumRecordAgeInSeconds Integer
    (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, Lambda never discards old records. The minimum valid value for maximum record age is 60s. Although values less than 60 and greater than -1 fall within the parameter's absolute range, they are not allowed
    maximumRetryAttempts Integer
    (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, Lambda retries failed records until the record expires in the event source.
    metricsConfig EventSourceMappingMetricsConfig
    The metrics configuration for your event source. For more information, see Event source mapping metrics.
    parallelizationFactor Integer
    (Kinesis and DynamoDB Streams only) The number of batches to process concurrently from each shard. The default value is 1.
    provisionedPollerConfig EventSourceMappingProvisionedPollerConfig
    (Amazon MSK and self-managed Apache Kafka only) The provisioned mode configuration for the event source. For more information, see provisioned mode.
    queues List<String>
    (Amazon MQ) The name of the Amazon MQ broker destination queue to consume.
    scalingConfig EventSourceMappingScalingConfig
    (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum concurrency for Amazon SQS event sources.
    selfManagedEventSource EventSourceMappingSelfManagedEventSource
    The self-managed Apache Kafka cluster for your event source.
    selfManagedKafkaEventSourceConfig EventSourceMappingSelfManagedKafkaEventSourceConfig
    Specific configuration settings for a self-managed Apache Kafka event source.
    sourceAccessConfigurations List<EventSourceMappingSourceAccessConfiguration>
    An array of the authentication protocol, VPC components, or virtual host to secure and define your event source.
    startingPosition String
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB.

    • LATEST - Read only new records.
    • TRIM_HORIZON - Process all available records.
    • AT_TIMESTAMP - Specify a time from which to start reading records.
    startingPositionTimestamp Double
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds. StartingPositionTimestamp cannot be in the future.
    tags List<Tag>
    A list of tags to add to the event source mapping. You must have the lambda:TagResource, lambda:UntagResource, and lambda:ListTags permissions for your principal to manage the CFN stack. If you don't have these permissions, there might be unexpected behavior with stack-level tags propagating to the resource during resource creation and update.
    topics List<String>
    The name of the Kafka topic.
    tumblingWindowInSeconds Integer
    (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis Streams event sources. A value of 0 seconds indicates no tumbling window.
    functionName string

    The name or ARN of the Lambda function. Name formats

    • Function name – MyFunction.
    • Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
    • Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
    • Partial ARN – 123456789012:function:MyFunction.

    The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 characters in length.

    amazonManagedKafkaEventSourceConfig EventSourceMappingAmazonManagedKafkaEventSourceConfig
    Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source.
    batchSize number
    The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation (6 MB).

    • Amazon Kinesis – Default 100. Max 10,000.
    • Amazon DynamoDB Streams – Default 100. Max 10,000.
    • Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues the max is 10.
    • Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000.
    • Self-managed Apache Kafka – Default 100. Max 10,000.
    • Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000.
    • DocumentDB – Default 100. Max 10,000.
    bisectBatchOnFunctionError boolean
    (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. The default value is false. When using BisectBatchOnFunctionError, check the BatchSize parameter in the OnFailure destination message's metadata. The BatchSize could be greater than 1 since LAM consolidates failed messages metadata when writing to the OnFailure destination.
    destinationConfig EventSourceMappingDestinationConfig
    (Kinesis, DynamoDB Streams, Amazon MSK, and self-managed Apache Kafka event sources only) A configuration object that specifies the destination of an event after Lambda processes it.
    documentDbEventSourceConfig EventSourceMappingDocumentDbEventSourceConfig
    Specific configuration settings for a DocumentDB event source.
    enabled boolean
    When true, the event source mapping is active. When false, Lambda pauses polling and invocation. Default: True
    eventSourceArn string
    The Amazon Resource Name (ARN) of the event source.

    • Amazon Kinesis – The ARN of the data stream or a stream consumer.
    • Amazon DynamoDB Streams – The ARN of the stream.
    • Amazon Simple Queue Service – The ARN of the queue.
    • Amazon Managed Streaming for Apache Kafka – The ARN of the cluster or the ARN of the VPC connection (for cross-account event source mappings).
    • Amazon MQ – The ARN of the broker.
    • Amazon DocumentDB – The ARN of the DocumentDB change stream.
    filterCriteria EventSourceMappingFilterCriteria
    An object that defines the filter criteria that determine whether Lambda should process an event. For more information, see Lambda event filtering.
    functionResponseTypes EventSourceMappingFunctionResponseTypesItem[]
    (Kinesis, DynamoDB Streams, and SQS) A list of current response type enums applied to the event source mapping. Valid Values: ReportBatchItemFailures
    kmsKeyArn string
    The ARN of the KMSlong (KMS) customer managed key that Lambda uses to encrypt your function's filter criteria.
    maximumBatchingWindowInSeconds number
    The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. Default (, , event sources): 0 Default (, Kafka, , event sources): 500 ms Related setting: For SQS event sources, when you set BatchSize to a value greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
    maximumRecordAgeInSeconds number
    (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, Lambda never discards old records. The minimum valid value for maximum record age is 60s. Although values less than 60 and greater than -1 fall within the parameter's absolute range, they are not allowed
    maximumRetryAttempts number
    (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, Lambda retries failed records until the record expires in the event source.
    metricsConfig EventSourceMappingMetricsConfig
    The metrics configuration for your event source. For more information, see Event source mapping metrics.
    parallelizationFactor number
    (Kinesis and DynamoDB Streams only) The number of batches to process concurrently from each shard. The default value is 1.
    provisionedPollerConfig EventSourceMappingProvisionedPollerConfig
    (Amazon MSK and self-managed Apache Kafka only) The provisioned mode configuration for the event source. For more information, see provisioned mode.
    queues string[]
    (Amazon MQ) The name of the Amazon MQ broker destination queue to consume.
    scalingConfig EventSourceMappingScalingConfig
    (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum concurrency for Amazon SQS event sources.
    selfManagedEventSource EventSourceMappingSelfManagedEventSource
    The self-managed Apache Kafka cluster for your event source.
    selfManagedKafkaEventSourceConfig EventSourceMappingSelfManagedKafkaEventSourceConfig
    Specific configuration settings for a self-managed Apache Kafka event source.
    sourceAccessConfigurations EventSourceMappingSourceAccessConfiguration[]
    An array of the authentication protocol, VPC components, or virtual host to secure and define your event source.
    startingPosition string
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB.

    • LATEST - Read only new records.
    • TRIM_HORIZON - Process all available records.
    • AT_TIMESTAMP - Specify a time from which to start reading records.
    startingPositionTimestamp number
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds. StartingPositionTimestamp cannot be in the future.
    tags Tag[]
    A list of tags to add to the event source mapping. You must have the lambda:TagResource, lambda:UntagResource, and lambda:ListTags permissions for your principal to manage the CFN stack. If you don't have these permissions, there might be unexpected behavior with stack-level tags propagating to the resource during resource creation and update.
    topics string[]
    The name of the Kafka topic.
    tumblingWindowInSeconds number
    (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis Streams event sources. A value of 0 seconds indicates no tumbling window.
    function_name str

    The name or ARN of the Lambda function. Name formats

    • Function name – MyFunction.
    • Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
    • Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
    • Partial ARN – 123456789012:function:MyFunction.

    The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 characters in length.

    amazon_managed_kafka_event_source_config EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs
    Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source.
    batch_size int
    The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation (6 MB).

    • Amazon Kinesis – Default 100. Max 10,000.
    • Amazon DynamoDB Streams – Default 100. Max 10,000.
    • Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues the max is 10.
    • Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000.
    • Self-managed Apache Kafka – Default 100. Max 10,000.
    • Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000.
    • DocumentDB – Default 100. Max 10,000.
    bisect_batch_on_function_error bool
    (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. The default value is false. When using BisectBatchOnFunctionError, check the BatchSize parameter in the OnFailure destination message's metadata. The BatchSize could be greater than 1 since LAM consolidates failed messages metadata when writing to the OnFailure destination.
    destination_config EventSourceMappingDestinationConfigArgs
    (Kinesis, DynamoDB Streams, Amazon MSK, and self-managed Apache Kafka event sources only) A configuration object that specifies the destination of an event after Lambda processes it.
    document_db_event_source_config EventSourceMappingDocumentDbEventSourceConfigArgs
    Specific configuration settings for a DocumentDB event source.
    enabled bool
    When true, the event source mapping is active. When false, Lambda pauses polling and invocation. Default: True
    event_source_arn str
    The Amazon Resource Name (ARN) of the event source.

    • Amazon Kinesis – The ARN of the data stream or a stream consumer.
    • Amazon DynamoDB Streams – The ARN of the stream.
    • Amazon Simple Queue Service – The ARN of the queue.
    • Amazon Managed Streaming for Apache Kafka – The ARN of the cluster or the ARN of the VPC connection (for cross-account event source mappings).
    • Amazon MQ – The ARN of the broker.
    • Amazon DocumentDB – The ARN of the DocumentDB change stream.
    filter_criteria EventSourceMappingFilterCriteriaArgs
    An object that defines the filter criteria that determine whether Lambda should process an event. For more information, see Lambda event filtering.
    function_response_types Sequence[EventSourceMappingFunctionResponseTypesItem]
    (Kinesis, DynamoDB Streams, and SQS) A list of current response type enums applied to the event source mapping. Valid Values: ReportBatchItemFailures
    kms_key_arn str
    The ARN of the KMSlong (KMS) customer managed key that Lambda uses to encrypt your function's filter criteria.
    maximum_batching_window_in_seconds int
    The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. Default (, , event sources): 0 Default (, Kafka, , event sources): 500 ms Related setting: For SQS event sources, when you set BatchSize to a value greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
    maximum_record_age_in_seconds int
    (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, Lambda never discards old records. The minimum valid value for maximum record age is 60s. Although values less than 60 and greater than -1 fall within the parameter's absolute range, they are not allowed
    maximum_retry_attempts int
    (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, Lambda retries failed records until the record expires in the event source.
    metrics_config EventSourceMappingMetricsConfigArgs
    The metrics configuration for your event source. For more information, see Event source mapping metrics.
    parallelization_factor int
    (Kinesis and DynamoDB Streams only) The number of batches to process concurrently from each shard. The default value is 1.
    provisioned_poller_config EventSourceMappingProvisionedPollerConfigArgs
    (Amazon MSK and self-managed Apache Kafka only) The provisioned mode configuration for the event source. For more information, see provisioned mode.
    queues Sequence[str]
    (Amazon MQ) The name of the Amazon MQ broker destination queue to consume.
    scaling_config EventSourceMappingScalingConfigArgs
    (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum concurrency for Amazon SQS event sources.
    self_managed_event_source EventSourceMappingSelfManagedEventSourceArgs
    The self-managed Apache Kafka cluster for your event source.
    self_managed_kafka_event_source_config EventSourceMappingSelfManagedKafkaEventSourceConfigArgs
    Specific configuration settings for a self-managed Apache Kafka event source.
    source_access_configurations Sequence[EventSourceMappingSourceAccessConfigurationArgs]
    An array of the authentication protocol, VPC components, or virtual host to secure and define your event source.
    starting_position str
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB.

    • LATEST - Read only new records.
    • TRIM_HORIZON - Process all available records.
    • AT_TIMESTAMP - Specify a time from which to start reading records.
    starting_position_timestamp float
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds. StartingPositionTimestamp cannot be in the future.
    tags Sequence[TagArgs]
    A list of tags to add to the event source mapping. You must have the lambda:TagResource, lambda:UntagResource, and lambda:ListTags permissions for your principal to manage the CFN stack. If you don't have these permissions, there might be unexpected behavior with stack-level tags propagating to the resource during resource creation and update.
    topics Sequence[str]
    The name of the Kafka topic.
    tumbling_window_in_seconds int
    (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis Streams event sources. A value of 0 seconds indicates no tumbling window.
    functionName String

    The name or ARN of the Lambda function. Name formats

    • Function name – MyFunction.
    • Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
    • Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
    • Partial ARN – 123456789012:function:MyFunction.

    The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 characters in length.

    amazonManagedKafkaEventSourceConfig Property Map
    Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source.
    batchSize Number
    The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit for synchronous invocation (6 MB).

    • Amazon Kinesis – Default 100. Max 10,000.
    • Amazon DynamoDB Streams – Default 100. Max 10,000.
    • Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues the max is 10.
    • Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000.
    • Self-managed Apache Kafka – Default 100. Max 10,000.
    • Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000.
    • DocumentDB – Default 100. Max 10,000.
    bisectBatchOnFunctionError Boolean
    (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. The default value is false. When using BisectBatchOnFunctionError, check the BatchSize parameter in the OnFailure destination message's metadata. The BatchSize could be greater than 1 since LAM consolidates failed messages metadata when writing to the OnFailure destination.
    destinationConfig Property Map
    (Kinesis, DynamoDB Streams, Amazon MSK, and self-managed Apache Kafka event sources only) A configuration object that specifies the destination of an event after Lambda processes it.
    documentDbEventSourceConfig Property Map
    Specific configuration settings for a DocumentDB event source.
    enabled Boolean
    When true, the event source mapping is active. When false, Lambda pauses polling and invocation. Default: True
    eventSourceArn String
    The Amazon Resource Name (ARN) of the event source.

    • Amazon Kinesis – The ARN of the data stream or a stream consumer.
    • Amazon DynamoDB Streams – The ARN of the stream.
    • Amazon Simple Queue Service – The ARN of the queue.
    • Amazon Managed Streaming for Apache Kafka – The ARN of the cluster or the ARN of the VPC connection (for cross-account event source mappings).
    • Amazon MQ – The ARN of the broker.
    • Amazon DocumentDB – The ARN of the DocumentDB change stream.
    filterCriteria Property Map
    An object that defines the filter criteria that determine whether Lambda should process an event. For more information, see Lambda event filtering.
    functionResponseTypes List<"ReportBatchItemFailures">
    (Kinesis, DynamoDB Streams, and SQS) A list of current response type enums applied to the event source mapping. Valid Values: ReportBatchItemFailures
    kmsKeyArn String
    The ARN of the KMSlong (KMS) customer managed key that Lambda uses to encrypt your function's filter criteria.
    maximumBatchingWindowInSeconds Number
    The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. Default (, , event sources): 0 Default (, Kafka, , event sources): 500 ms Related setting: For SQS event sources, when you set BatchSize to a value greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
    maximumRecordAgeInSeconds Number
    (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, Lambda never discards old records. The minimum valid value for maximum record age is 60s. Although values less than 60 and greater than -1 fall within the parameter's absolute range, they are not allowed
    maximumRetryAttempts Number
    (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, Lambda retries failed records until the record expires in the event source.
    metricsConfig Property Map
    The metrics configuration for your event source. For more information, see Event source mapping metrics.
    parallelizationFactor Number
    (Kinesis and DynamoDB Streams only) The number of batches to process concurrently from each shard. The default value is 1.
    provisionedPollerConfig Property Map
    (Amazon MSK and self-managed Apache Kafka only) The provisioned mode configuration for the event source. For more information, see provisioned mode.
    queues List<String>
    (Amazon MQ) The name of the Amazon MQ broker destination queue to consume.
    scalingConfig Property Map
    (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum concurrency for Amazon SQS event sources.
    selfManagedEventSource Property Map
    The self-managed Apache Kafka cluster for your event source.
    selfManagedKafkaEventSourceConfig Property Map
    Specific configuration settings for a self-managed Apache Kafka event source.
    sourceAccessConfigurations List<Property Map>
    An array of the authentication protocol, VPC components, or virtual host to secure and define your event source.
    startingPosition String
    The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB.

    • LATEST - Read only new records.
    • TRIM_HORIZON - Process all available records.
    • AT_TIMESTAMP - Specify a time from which to start reading records.
    startingPositionTimestamp Number
    With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds. StartingPositionTimestamp cannot be in the future.
    tags List<Property Map>
    A list of tags to add to the event source mapping. You must have the lambda:TagResource, lambda:UntagResource, and lambda:ListTags permissions for your principal to manage the CFN stack. If you don't have these permissions, there might be unexpected behavior with stack-level tags propagating to the resource during resource creation and update.
    topics List<String>
    The name of the Kafka topic.
    tumblingWindowInSeconds Number
    (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis Streams event sources. A value of 0 seconds indicates no tumbling window.

    Outputs

    All input properties are implicitly available as output properties. Additionally, the EventSourceMapping resource produces the following output properties:

    AwsId string
    The event source mapping's ID.
    EventSourceMappingArn string
    The Amazon Resource Name (ARN) of the event source mapping.
    Id string
    The provider-assigned unique ID for this managed resource.
    AwsId string
    The event source mapping's ID.
    EventSourceMappingArn string
    The Amazon Resource Name (ARN) of the event source mapping.
    Id string
    The provider-assigned unique ID for this managed resource.
    awsId String
    The event source mapping's ID.
    eventSourceMappingArn String
    The Amazon Resource Name (ARN) of the event source mapping.
    id String
    The provider-assigned unique ID for this managed resource.
    awsId string
    The event source mapping's ID.
    eventSourceMappingArn string
    The Amazon Resource Name (ARN) of the event source mapping.
    id string
    The provider-assigned unique ID for this managed resource.
    aws_id str
    The event source mapping's ID.
    event_source_mapping_arn str
    The Amazon Resource Name (ARN) of the event source mapping.
    id str
    The provider-assigned unique ID for this managed resource.
    awsId String
    The event source mapping's ID.
    eventSourceMappingArn String
    The Amazon Resource Name (ARN) of the event source mapping.
    id String
    The provider-assigned unique ID for this managed resource.

    Supporting Types

    EventSourceMappingAmazonManagedKafkaEventSourceConfig, EventSourceMappingAmazonManagedKafkaEventSourceConfigArgs

    Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source.
    ConsumerGroupId string
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    SchemaRegistryConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingSchemaRegistryConfig
    Specific configuration settings for a Kafka schema registry.
    ConsumerGroupId string
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    SchemaRegistryConfig EventSourceMappingSchemaRegistryConfig
    Specific configuration settings for a Kafka schema registry.
    consumerGroupId String
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    schemaRegistryConfig EventSourceMappingSchemaRegistryConfig
    Specific configuration settings for a Kafka schema registry.
    consumerGroupId string
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    schemaRegistryConfig EventSourceMappingSchemaRegistryConfig
    Specific configuration settings for a Kafka schema registry.
    consumer_group_id str
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    schema_registry_config EventSourceMappingSchemaRegistryConfig
    Specific configuration settings for a Kafka schema registry.
    consumerGroupId String
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    schemaRegistryConfig Property Map
    Specific configuration settings for a Kafka schema registry.

    EventSourceMappingDestinationConfig, EventSourceMappingDestinationConfigArgs

    A configuration object that specifies the destination of an event after Lambda processes it. For more information, see Adding a destination.
    OnFailure Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingOnFailure
    The destination configuration for failed invocations.
    OnFailure EventSourceMappingOnFailure
    The destination configuration for failed invocations.
    onFailure EventSourceMappingOnFailure
    The destination configuration for failed invocations.
    onFailure EventSourceMappingOnFailure
    The destination configuration for failed invocations.
    on_failure EventSourceMappingOnFailure
    The destination configuration for failed invocations.
    onFailure Property Map
    The destination configuration for failed invocations.

    EventSourceMappingDocumentDbEventSourceConfig, EventSourceMappingDocumentDbEventSourceConfigArgs

    Specific configuration settings for a DocumentDB event source.
    CollectionName string
    The name of the collection to consume within the database. If you do not specify a collection, Lambda consumes all collections.
    DatabaseName string
    The name of the database to consume within the DocumentDB cluster.
    FullDocument Pulumi.AwsNative.Lambda.EventSourceMappingDocumentDbEventSourceConfigFullDocument
    Determines what DocumentDB sends to your event stream during document update operations. If set to UpdateLookup, DocumentDB sends a delta describing the changes, along with a copy of the entire document. Otherwise, DocumentDB sends only a partial document that contains the changes.
    CollectionName string
    The name of the collection to consume within the database. If you do not specify a collection, Lambda consumes all collections.
    DatabaseName string
    The name of the database to consume within the DocumentDB cluster.
    FullDocument EventSourceMappingDocumentDbEventSourceConfigFullDocument
    Determines what DocumentDB sends to your event stream during document update operations. If set to UpdateLookup, DocumentDB sends a delta describing the changes, along with a copy of the entire document. Otherwise, DocumentDB sends only a partial document that contains the changes.
    collectionName String
    The name of the collection to consume within the database. If you do not specify a collection, Lambda consumes all collections.
    databaseName String
    The name of the database to consume within the DocumentDB cluster.
    fullDocument EventSourceMappingDocumentDbEventSourceConfigFullDocument
    Determines what DocumentDB sends to your event stream during document update operations. If set to UpdateLookup, DocumentDB sends a delta describing the changes, along with a copy of the entire document. Otherwise, DocumentDB sends only a partial document that contains the changes.
    collectionName string
    The name of the collection to consume within the database. If you do not specify a collection, Lambda consumes all collections.
    databaseName string
    The name of the database to consume within the DocumentDB cluster.
    fullDocument EventSourceMappingDocumentDbEventSourceConfigFullDocument
    Determines what DocumentDB sends to your event stream during document update operations. If set to UpdateLookup, DocumentDB sends a delta describing the changes, along with a copy of the entire document. Otherwise, DocumentDB sends only a partial document that contains the changes.
    collection_name str
    The name of the collection to consume within the database. If you do not specify a collection, Lambda consumes all collections.
    database_name str
    The name of the database to consume within the DocumentDB cluster.
    full_document EventSourceMappingDocumentDbEventSourceConfigFullDocument
    Determines what DocumentDB sends to your event stream during document update operations. If set to UpdateLookup, DocumentDB sends a delta describing the changes, along with a copy of the entire document. Otherwise, DocumentDB sends only a partial document that contains the changes.
    collectionName String
    The name of the collection to consume within the database. If you do not specify a collection, Lambda consumes all collections.
    databaseName String
    The name of the database to consume within the DocumentDB cluster.
    fullDocument "UpdateLookup" | "Default"
    Determines what DocumentDB sends to your event stream during document update operations. If set to UpdateLookup, DocumentDB sends a delta describing the changes, along with a copy of the entire document. Otherwise, DocumentDB sends only a partial document that contains the changes.

    EventSourceMappingDocumentDbEventSourceConfigFullDocument, EventSourceMappingDocumentDbEventSourceConfigFullDocumentArgs

    UpdateLookup
    UpdateLookup
    Default
    Default
    EventSourceMappingDocumentDbEventSourceConfigFullDocumentUpdateLookup
    UpdateLookup
    EventSourceMappingDocumentDbEventSourceConfigFullDocumentDefault
    Default
    UpdateLookup
    UpdateLookup
    Default
    Default
    UpdateLookup
    UpdateLookup
    Default
    Default
    UPDATE_LOOKUP
    UpdateLookup
    DEFAULT
    Default
    "UpdateLookup"
    UpdateLookup
    "Default"
    Default

    EventSourceMappingEndpoints, EventSourceMappingEndpointsArgs

    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    KafkaBootstrapServers List<string>
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    KafkaBootstrapServers []string
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    kafkaBootstrapServers List<String>
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    kafkaBootstrapServers string[]
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    kafka_bootstrap_servers Sequence[str]
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    kafkaBootstrapServers List<String>
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

    EventSourceMappingFilter, EventSourceMappingFilterArgs

    A structure within a FilterCriteria object that defines an event filtering pattern.
    Pattern string
    A filter pattern. For more information on the syntax of a filter pattern, see Filter rule syntax.
    Pattern string
    A filter pattern. For more information on the syntax of a filter pattern, see Filter rule syntax.
    pattern String
    A filter pattern. For more information on the syntax of a filter pattern, see Filter rule syntax.
    pattern string
    A filter pattern. For more information on the syntax of a filter pattern, see Filter rule syntax.
    pattern str
    A filter pattern. For more information on the syntax of a filter pattern, see Filter rule syntax.
    pattern String
    A filter pattern. For more information on the syntax of a filter pattern, see Filter rule syntax.

    EventSourceMappingFilterCriteria, EventSourceMappingFilterCriteriaArgs

    An object that contains the filters for an event source.
    filters List<Property Map>
    A list of filters.

    EventSourceMappingFunctionResponseTypesItem, EventSourceMappingFunctionResponseTypesItemArgs

    ReportBatchItemFailures
    ReportBatchItemFailures
    EventSourceMappingFunctionResponseTypesItemReportBatchItemFailures
    ReportBatchItemFailures
    ReportBatchItemFailures
    ReportBatchItemFailures
    ReportBatchItemFailures
    ReportBatchItemFailures
    REPORT_BATCH_ITEM_FAILURES
    ReportBatchItemFailures
    "ReportBatchItemFailures"
    ReportBatchItemFailures

    EventSourceMappingMetricsConfig, EventSourceMappingMetricsConfigArgs

    The metrics configuration for your event source. Use this configuration object to define which metrics you want your event source mapping to produce.
    Metrics List<Pulumi.AwsNative.Lambda.EventSourceMappingMetricsConfigMetricsItem>
    The metrics you want your event source mapping to produce. Include EventCount to receive event source mapping metrics related to the number of events processed by your event source mapping. For more information about these metrics, see Event source mapping metrics.
    Metrics []EventSourceMappingMetricsConfigMetricsItem
    The metrics you want your event source mapping to produce. Include EventCount to receive event source mapping metrics related to the number of events processed by your event source mapping. For more information about these metrics, see Event source mapping metrics.
    metrics List<EventSourceMappingMetricsConfigMetricsItem>
    The metrics you want your event source mapping to produce. Include EventCount to receive event source mapping metrics related to the number of events processed by your event source mapping. For more information about these metrics, see Event source mapping metrics.
    metrics EventSourceMappingMetricsConfigMetricsItem[]
    The metrics you want your event source mapping to produce. Include EventCount to receive event source mapping metrics related to the number of events processed by your event source mapping. For more information about these metrics, see Event source mapping metrics.
    metrics Sequence[EventSourceMappingMetricsConfigMetricsItem]
    The metrics you want your event source mapping to produce. Include EventCount to receive event source mapping metrics related to the number of events processed by your event source mapping. For more information about these metrics, see Event source mapping metrics.
    metrics List<"EventCount">
    The metrics you want your event source mapping to produce. Include EventCount to receive event source mapping metrics related to the number of events processed by your event source mapping. For more information about these metrics, see Event source mapping metrics.

    EventSourceMappingMetricsConfigMetricsItem, EventSourceMappingMetricsConfigMetricsItemArgs

    EventCount
    EventCount
    EventSourceMappingMetricsConfigMetricsItemEventCount
    EventCount
    EventCount
    EventCount
    EventCount
    EventCount
    EVENT_COUNT
    EventCount
    "EventCount"
    EventCount

    EventSourceMappingOnFailure, EventSourceMappingOnFailureArgs

    A destination for events that failed processing. For more information, see Adding a destination.
    Destination string
    The Amazon Resource Name (ARN) of the destination resource. To retain records of unsuccessful asynchronous invocations, you can configure an Amazon SNS topic, Amazon SQS queue, Amazon S3 bucket, Lambda function, or Amazon EventBridge event bus as the destination. To retain records of failed invocations from Kinesis, DynamoDB, self-managed Kafka or Amazon MSK, you can configure an Amazon SNS topic, Amazon SQS queue, or Amazon S3 bucket as the destination.
    Destination string
    The Amazon Resource Name (ARN) of the destination resource. To retain records of unsuccessful asynchronous invocations, you can configure an Amazon SNS topic, Amazon SQS queue, Amazon S3 bucket, Lambda function, or Amazon EventBridge event bus as the destination. To retain records of failed invocations from Kinesis, DynamoDB, self-managed Kafka or Amazon MSK, you can configure an Amazon SNS topic, Amazon SQS queue, or Amazon S3 bucket as the destination.
    destination String
    The Amazon Resource Name (ARN) of the destination resource. To retain records of unsuccessful asynchronous invocations, you can configure an Amazon SNS topic, Amazon SQS queue, Amazon S3 bucket, Lambda function, or Amazon EventBridge event bus as the destination. To retain records of failed invocations from Kinesis, DynamoDB, self-managed Kafka or Amazon MSK, you can configure an Amazon SNS topic, Amazon SQS queue, or Amazon S3 bucket as the destination.
    destination string
    The Amazon Resource Name (ARN) of the destination resource. To retain records of unsuccessful asynchronous invocations, you can configure an Amazon SNS topic, Amazon SQS queue, Amazon S3 bucket, Lambda function, or Amazon EventBridge event bus as the destination. To retain records of failed invocations from Kinesis, DynamoDB, self-managed Kafka or Amazon MSK, you can configure an Amazon SNS topic, Amazon SQS queue, or Amazon S3 bucket as the destination.
    destination str
    The Amazon Resource Name (ARN) of the destination resource. To retain records of unsuccessful asynchronous invocations, you can configure an Amazon SNS topic, Amazon SQS queue, Amazon S3 bucket, Lambda function, or Amazon EventBridge event bus as the destination. To retain records of failed invocations from Kinesis, DynamoDB, self-managed Kafka or Amazon MSK, you can configure an Amazon SNS topic, Amazon SQS queue, or Amazon S3 bucket as the destination.
    destination String
    The Amazon Resource Name (ARN) of the destination resource. To retain records of unsuccessful asynchronous invocations, you can configure an Amazon SNS topic, Amazon SQS queue, Amazon S3 bucket, Lambda function, or Amazon EventBridge event bus as the destination. To retain records of failed invocations from Kinesis, DynamoDB, self-managed Kafka or Amazon MSK, you can configure an Amazon SNS topic, Amazon SQS queue, or Amazon S3 bucket as the destination.

    EventSourceMappingProvisionedPollerConfig, EventSourceMappingProvisionedPollerConfigArgs

    The provisioned mode configuration for the event source. Use provisioned mode to customize the minimum and maximum number of event pollers for your event source.
    MaximumPollers int
    The maximum number of event pollers this event source can scale up to.
    MinimumPollers int
    The minimum number of event pollers this event source can scale down to.
    MaximumPollers int
    The maximum number of event pollers this event source can scale up to.
    MinimumPollers int
    The minimum number of event pollers this event source can scale down to.
    maximumPollers Integer
    The maximum number of event pollers this event source can scale up to.
    minimumPollers Integer
    The minimum number of event pollers this event source can scale down to.
    maximumPollers number
    The maximum number of event pollers this event source can scale up to.
    minimumPollers number
    The minimum number of event pollers this event source can scale down to.
    maximum_pollers int
    The maximum number of event pollers this event source can scale up to.
    minimum_pollers int
    The minimum number of event pollers this event source can scale down to.
    maximumPollers Number
    The maximum number of event pollers this event source can scale up to.
    minimumPollers Number
    The minimum number of event pollers this event source can scale down to.

    EventSourceMappingScalingConfig, EventSourceMappingScalingConfigArgs

    (Amazon SQS only) The scaling configuration for the event source. To remove the configuration, pass an empty value.
    MaximumConcurrency int
    Limits the number of concurrent instances that the SQS event source can invoke.
    MaximumConcurrency int
    Limits the number of concurrent instances that the SQS event source can invoke.
    maximumConcurrency Integer
    Limits the number of concurrent instances that the SQS event source can invoke.
    maximumConcurrency number
    Limits the number of concurrent instances that the SQS event source can invoke.
    maximum_concurrency int
    Limits the number of concurrent instances that the SQS event source can invoke.
    maximumConcurrency Number
    Limits the number of concurrent instances that the SQS event source can invoke.

    EventSourceMappingSchemaRegistryAccessConfig, EventSourceMappingSchemaRegistryAccessConfigArgs

    Specific access configuration settings that tell Lambda how to authenticate with your schema registry. If you're working with an GLU schema registry, don't provide authentication details in this object. Instead, ensure that your execution role has the required permissions for Lambda to access your cluster. If you're working with a Confluent schema registry, choose the authentication method in the Type field, and provide the ASMlong secret ARN in the URI field.
    Type Pulumi.AwsNative.Lambda.EventSourceMappingSchemaRegistryAccessConfigType
    The type of authentication Lambda uses to access your schema registry.
    Uri string
    The URI of the secret (Secrets Manager secret ARN) to authenticate with your schema registry.
    Type EventSourceMappingSchemaRegistryAccessConfigType
    The type of authentication Lambda uses to access your schema registry.
    Uri string
    The URI of the secret (Secrets Manager secret ARN) to authenticate with your schema registry.
    type EventSourceMappingSchemaRegistryAccessConfigType
    The type of authentication Lambda uses to access your schema registry.
    uri String
    The URI of the secret (Secrets Manager secret ARN) to authenticate with your schema registry.
    type EventSourceMappingSchemaRegistryAccessConfigType
    The type of authentication Lambda uses to access your schema registry.
    uri string
    The URI of the secret (Secrets Manager secret ARN) to authenticate with your schema registry.
    type EventSourceMappingSchemaRegistryAccessConfigType
    The type of authentication Lambda uses to access your schema registry.
    uri str
    The URI of the secret (Secrets Manager secret ARN) to authenticate with your schema registry.
    type "BASIC_AUTH" | "CLIENT_CERTIFICATE_TLS_AUTH" | "SERVER_ROOT_CA_CERTIFICATE"
    The type of authentication Lambda uses to access your schema registry.
    uri String
    The URI of the secret (Secrets Manager secret ARN) to authenticate with your schema registry.

    EventSourceMappingSchemaRegistryAccessConfigType, EventSourceMappingSchemaRegistryAccessConfigTypeArgs

    BasicAuth
    BASIC_AUTH
    ClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    ServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    EventSourceMappingSchemaRegistryAccessConfigTypeBasicAuth
    BASIC_AUTH
    EventSourceMappingSchemaRegistryAccessConfigTypeClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    EventSourceMappingSchemaRegistryAccessConfigTypeServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    BasicAuth
    BASIC_AUTH
    ClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    ServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    BasicAuth
    BASIC_AUTH
    ClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    ServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    BASIC_AUTH
    BASIC_AUTH
    CLIENT_CERTIFICATE_TLS_AUTH
    CLIENT_CERTIFICATE_TLS_AUTH
    SERVER_ROOT_CA_CERTIFICATE
    SERVER_ROOT_CA_CERTIFICATE
    "BASIC_AUTH"
    BASIC_AUTH
    "CLIENT_CERTIFICATE_TLS_AUTH"
    CLIENT_CERTIFICATE_TLS_AUTH
    "SERVER_ROOT_CA_CERTIFICATE"
    SERVER_ROOT_CA_CERTIFICATE

    EventSourceMappingSchemaRegistryConfig, EventSourceMappingSchemaRegistryConfigArgs

    Specific configuration settings for a Kafka schema registry.
    AccessConfigs List<Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingSchemaRegistryAccessConfig>
    An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
    EventRecordFormat Pulumi.AwsNative.Lambda.EventSourceMappingSchemaRegistryConfigEventRecordFormat
    The record format that Lambda delivers to your function after schema validation.

    • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.
    • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.
    SchemaRegistryUri string
    The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

    • For GLU schema registries, use the ARN of the registry.
    • For Confluent schema registries, use the URL of the registry.
    SchemaValidationConfigs List<Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingSchemaValidationConfig>
    An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
    AccessConfigs []EventSourceMappingSchemaRegistryAccessConfig
    An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
    EventRecordFormat EventSourceMappingSchemaRegistryConfigEventRecordFormat
    The record format that Lambda delivers to your function after schema validation.

    • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.
    • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.
    SchemaRegistryUri string
    The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

    • For GLU schema registries, use the ARN of the registry.
    • For Confluent schema registries, use the URL of the registry.
    SchemaValidationConfigs []EventSourceMappingSchemaValidationConfig
    An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
    accessConfigs List<EventSourceMappingSchemaRegistryAccessConfig>
    An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
    eventRecordFormat EventSourceMappingSchemaRegistryConfigEventRecordFormat
    The record format that Lambda delivers to your function after schema validation.

    • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.
    • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.
    schemaRegistryUri String
    The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

    • For GLU schema registries, use the ARN of the registry.
    • For Confluent schema registries, use the URL of the registry.
    schemaValidationConfigs List<EventSourceMappingSchemaValidationConfig>
    An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
    accessConfigs EventSourceMappingSchemaRegistryAccessConfig[]
    An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
    eventRecordFormat EventSourceMappingSchemaRegistryConfigEventRecordFormat
    The record format that Lambda delivers to your function after schema validation.

    • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.
    • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.
    schemaRegistryUri string
    The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

    • For GLU schema registries, use the ARN of the registry.
    • For Confluent schema registries, use the URL of the registry.
    schemaValidationConfigs EventSourceMappingSchemaValidationConfig[]
    An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
    access_configs Sequence[EventSourceMappingSchemaRegistryAccessConfig]
    An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
    event_record_format EventSourceMappingSchemaRegistryConfigEventRecordFormat
    The record format that Lambda delivers to your function after schema validation.

    • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.
    • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.
    schema_registry_uri str
    The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

    • For GLU schema registries, use the ARN of the registry.
    • For Confluent schema registries, use the URL of the registry.
    schema_validation_configs Sequence[EventSourceMappingSchemaValidationConfig]
    An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
    accessConfigs List<Property Map>
    An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
    eventRecordFormat "JSON" | "SOURCE"
    The record format that Lambda delivers to your function after schema validation.

    • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.
    • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.
    schemaRegistryUri String
    The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

    • For GLU schema registries, use the ARN of the registry.
    • For Confluent schema registries, use the URL of the registry.
    schemaValidationConfigs List<Property Map>
    An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.

    EventSourceMappingSchemaRegistryConfigEventRecordFormat, EventSourceMappingSchemaRegistryConfigEventRecordFormatArgs

    Json
    JSON
    Source
    SOURCE
    EventSourceMappingSchemaRegistryConfigEventRecordFormatJson
    JSON
    EventSourceMappingSchemaRegistryConfigEventRecordFormatSource
    SOURCE
    Json
    JSON
    Source
    SOURCE
    Json
    JSON
    Source
    SOURCE
    JSON
    JSON
    SOURCE
    SOURCE
    "JSON"
    JSON
    "SOURCE"
    SOURCE

    EventSourceMappingSchemaValidationConfig, EventSourceMappingSchemaValidationConfigArgs

    Specific schema validation configuration settings that tell Lambda the message attributes you want to validate and filter using your schema registry.
    Attribute Pulumi.AwsNative.Lambda.EventSourceMappingSchemaValidationConfigAttribute
    The attributes you want your schema registry to validate and filter for. If you selected JSON as the EventRecordFormat, Lambda also deserializes the selected message attributes.
    Attribute EventSourceMappingSchemaValidationConfigAttribute
    The attributes you want your schema registry to validate and filter for. If you selected JSON as the EventRecordFormat, Lambda also deserializes the selected message attributes.
    attribute EventSourceMappingSchemaValidationConfigAttribute
    The attributes you want your schema registry to validate and filter for. If you selected JSON as the EventRecordFormat, Lambda also deserializes the selected message attributes.
    attribute EventSourceMappingSchemaValidationConfigAttribute
    The attributes you want your schema registry to validate and filter for. If you selected JSON as the EventRecordFormat, Lambda also deserializes the selected message attributes.
    attribute EventSourceMappingSchemaValidationConfigAttribute
    The attributes you want your schema registry to validate and filter for. If you selected JSON as the EventRecordFormat, Lambda also deserializes the selected message attributes.
    attribute "KEY" | "VALUE"
    The attributes you want your schema registry to validate and filter for. If you selected JSON as the EventRecordFormat, Lambda also deserializes the selected message attributes.

    EventSourceMappingSchemaValidationConfigAttribute, EventSourceMappingSchemaValidationConfigAttributeArgs

    Key
    KEY
    Value
    VALUE
    EventSourceMappingSchemaValidationConfigAttributeKey
    KEY
    EventSourceMappingSchemaValidationConfigAttributeValue
    VALUE
    Key
    KEY
    Value
    VALUE
    Key
    KEY
    Value
    VALUE
    KEY
    KEY
    VALUE
    VALUE
    "KEY"
    KEY
    "VALUE"
    VALUE

    EventSourceMappingSelfManagedEventSource, EventSourceMappingSelfManagedEventSourceArgs

    The self-managed Apache Kafka cluster for your event source.
    Endpoints Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingEndpoints
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    Endpoints EventSourceMappingEndpoints
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    endpoints EventSourceMappingEndpoints
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    endpoints EventSourceMappingEndpoints
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    endpoints EventSourceMappingEndpoints
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].
    endpoints Property Map
    The list of bootstrap servers for your Kafka brokers in the following format: "KafkaBootstrapServers": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

    EventSourceMappingSelfManagedKafkaEventSourceConfig, EventSourceMappingSelfManagedKafkaEventSourceConfigArgs

    Specific configuration settings for a self-managed Apache Kafka event source.
    ConsumerGroupId string
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    SchemaRegistryConfig Pulumi.AwsNative.Lambda.Inputs.EventSourceMappingSchemaRegistryConfig
    Specific configuration settings for a Kafka schema registry.
    ConsumerGroupId string
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    SchemaRegistryConfig EventSourceMappingSchemaRegistryConfig
    Specific configuration settings for a Kafka schema registry.
    consumerGroupId String
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    schemaRegistryConfig EventSourceMappingSchemaRegistryConfig
    Specific configuration settings for a Kafka schema registry.
    consumerGroupId string
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    schemaRegistryConfig EventSourceMappingSchemaRegistryConfig
    Specific configuration settings for a Kafka schema registry.
    consumer_group_id str
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    schema_registry_config EventSourceMappingSchemaRegistryConfig
    Specific configuration settings for a Kafka schema registry.
    consumerGroupId String
    The identifier for the Kafka consumer group to join. The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID.
    schemaRegistryConfig Property Map
    Specific configuration settings for a Kafka schema registry.

    EventSourceMappingSourceAccessConfiguration, EventSourceMappingSourceAccessConfigurationArgs

    An array of the authentication protocol, VPC components, or virtual host to secure and define your event source.
    Type Pulumi.AwsNative.Lambda.EventSourceMappingSourceAccessConfigurationType
    The type of authentication protocol, VPC components, or virtual host for your event source. For example: "Type":"SASL_SCRAM_512_AUTH".

    • BASIC_AUTH – (Amazon MQ) The ASMlong secret that stores your broker credentials.
    • BASIC_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL/PLAIN authentication of your Apache Kafka brokers.
    • VPC_SUBNET – (Self-managed Apache Kafka) The subnets associated with your VPC. Lambda connects to these subnets to fetch data from your self-managed Apache Kafka cluster.
    • VPC_SECURITY_GROUP – (Self-managed Apache Kafka) The VPC security group used to manage access to your self-managed Apache Kafka brokers.
    • SASL_SCRAM_256_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-256 authentication of your self-managed Apache Kafka brokers.
    • SASL_SCRAM_512_AUTH – (Amazon MSK, Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-512 authentication of your self-managed Apache Kafka brokers.
    • VIRTUAL_HOST –- (RabbitMQ) The name of the virtual host in your RabbitMQ broker. Lambda uses this RabbitMQ host as the event source. This property cannot be specified in an UpdateEventSourceMapping API call.
    • CLIENT_CERTIFICATE_TLS_AUTH – (Amazon MSK, self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the certificate chain (X.509 PEM), private key (PKCS#8 PEM), and private key password (optional) used for mutual TLS authentication of your MSK/Apache Kafka brokers.
    • SERVER_ROOT_CA_CERTIFICATE – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the root CA certificate (X.509 PEM) used for TLS encryption of your Apache Kafka brokers.
    Uri string
    The value for your chosen configuration in Type. For example: "URI": "arn:aws:secretsmanager:us-east-1:01234567890:secret:MyBrokerSecretName".
    Type EventSourceMappingSourceAccessConfigurationType
    The type of authentication protocol, VPC components, or virtual host for your event source. For example: "Type":"SASL_SCRAM_512_AUTH".

    • BASIC_AUTH – (Amazon MQ) The ASMlong secret that stores your broker credentials.
    • BASIC_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL/PLAIN authentication of your Apache Kafka brokers.
    • VPC_SUBNET – (Self-managed Apache Kafka) The subnets associated with your VPC. Lambda connects to these subnets to fetch data from your self-managed Apache Kafka cluster.
    • VPC_SECURITY_GROUP – (Self-managed Apache Kafka) The VPC security group used to manage access to your self-managed Apache Kafka brokers.
    • SASL_SCRAM_256_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-256 authentication of your self-managed Apache Kafka brokers.
    • SASL_SCRAM_512_AUTH – (Amazon MSK, Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-512 authentication of your self-managed Apache Kafka brokers.
    • VIRTUAL_HOST –- (RabbitMQ) The name of the virtual host in your RabbitMQ broker. Lambda uses this RabbitMQ host as the event source. This property cannot be specified in an UpdateEventSourceMapping API call.
    • CLIENT_CERTIFICATE_TLS_AUTH – (Amazon MSK, self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the certificate chain (X.509 PEM), private key (PKCS#8 PEM), and private key password (optional) used for mutual TLS authentication of your MSK/Apache Kafka brokers.
    • SERVER_ROOT_CA_CERTIFICATE – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the root CA certificate (X.509 PEM) used for TLS encryption of your Apache Kafka brokers.
    Uri string
    The value for your chosen configuration in Type. For example: "URI": "arn:aws:secretsmanager:us-east-1:01234567890:secret:MyBrokerSecretName".
    type EventSourceMappingSourceAccessConfigurationType
    The type of authentication protocol, VPC components, or virtual host for your event source. For example: "Type":"SASL_SCRAM_512_AUTH".

    • BASIC_AUTH – (Amazon MQ) The ASMlong secret that stores your broker credentials.
    • BASIC_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL/PLAIN authentication of your Apache Kafka brokers.
    • VPC_SUBNET – (Self-managed Apache Kafka) The subnets associated with your VPC. Lambda connects to these subnets to fetch data from your self-managed Apache Kafka cluster.
    • VPC_SECURITY_GROUP – (Self-managed Apache Kafka) The VPC security group used to manage access to your self-managed Apache Kafka brokers.
    • SASL_SCRAM_256_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-256 authentication of your self-managed Apache Kafka brokers.
    • SASL_SCRAM_512_AUTH – (Amazon MSK, Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-512 authentication of your self-managed Apache Kafka brokers.
    • VIRTUAL_HOST –- (RabbitMQ) The name of the virtual host in your RabbitMQ broker. Lambda uses this RabbitMQ host as the event source. This property cannot be specified in an UpdateEventSourceMapping API call.
    • CLIENT_CERTIFICATE_TLS_AUTH – (Amazon MSK, self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the certificate chain (X.509 PEM), private key (PKCS#8 PEM), and private key password (optional) used for mutual TLS authentication of your MSK/Apache Kafka brokers.
    • SERVER_ROOT_CA_CERTIFICATE – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the root CA certificate (X.509 PEM) used for TLS encryption of your Apache Kafka brokers.
    uri String
    The value for your chosen configuration in Type. For example: "URI": "arn:aws:secretsmanager:us-east-1:01234567890:secret:MyBrokerSecretName".
    type EventSourceMappingSourceAccessConfigurationType
    The type of authentication protocol, VPC components, or virtual host for your event source. For example: "Type":"SASL_SCRAM_512_AUTH".

    • BASIC_AUTH – (Amazon MQ) The ASMlong secret that stores your broker credentials.
    • BASIC_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL/PLAIN authentication of your Apache Kafka brokers.
    • VPC_SUBNET – (Self-managed Apache Kafka) The subnets associated with your VPC. Lambda connects to these subnets to fetch data from your self-managed Apache Kafka cluster.
    • VPC_SECURITY_GROUP – (Self-managed Apache Kafka) The VPC security group used to manage access to your self-managed Apache Kafka brokers.
    • SASL_SCRAM_256_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-256 authentication of your self-managed Apache Kafka brokers.
    • SASL_SCRAM_512_AUTH – (Amazon MSK, Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-512 authentication of your self-managed Apache Kafka brokers.
    • VIRTUAL_HOST –- (RabbitMQ) The name of the virtual host in your RabbitMQ broker. Lambda uses this RabbitMQ host as the event source. This property cannot be specified in an UpdateEventSourceMapping API call.
    • CLIENT_CERTIFICATE_TLS_AUTH – (Amazon MSK, self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the certificate chain (X.509 PEM), private key (PKCS#8 PEM), and private key password (optional) used for mutual TLS authentication of your MSK/Apache Kafka brokers.
    • SERVER_ROOT_CA_CERTIFICATE – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the root CA certificate (X.509 PEM) used for TLS encryption of your Apache Kafka brokers.
    uri string
    The value for your chosen configuration in Type. For example: "URI": "arn:aws:secretsmanager:us-east-1:01234567890:secret:MyBrokerSecretName".
    type EventSourceMappingSourceAccessConfigurationType
    The type of authentication protocol, VPC components, or virtual host for your event source. For example: "Type":"SASL_SCRAM_512_AUTH".

    • BASIC_AUTH – (Amazon MQ) The ASMlong secret that stores your broker credentials.
    • BASIC_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL/PLAIN authentication of your Apache Kafka brokers.
    • VPC_SUBNET – (Self-managed Apache Kafka) The subnets associated with your VPC. Lambda connects to these subnets to fetch data from your self-managed Apache Kafka cluster.
    • VPC_SECURITY_GROUP – (Self-managed Apache Kafka) The VPC security group used to manage access to your self-managed Apache Kafka brokers.
    • SASL_SCRAM_256_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-256 authentication of your self-managed Apache Kafka brokers.
    • SASL_SCRAM_512_AUTH – (Amazon MSK, Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-512 authentication of your self-managed Apache Kafka brokers.
    • VIRTUAL_HOST –- (RabbitMQ) The name of the virtual host in your RabbitMQ broker. Lambda uses this RabbitMQ host as the event source. This property cannot be specified in an UpdateEventSourceMapping API call.
    • CLIENT_CERTIFICATE_TLS_AUTH – (Amazon MSK, self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the certificate chain (X.509 PEM), private key (PKCS#8 PEM), and private key password (optional) used for mutual TLS authentication of your MSK/Apache Kafka brokers.
    • SERVER_ROOT_CA_CERTIFICATE – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the root CA certificate (X.509 PEM) used for TLS encryption of your Apache Kafka brokers.
    uri str
    The value for your chosen configuration in Type. For example: "URI": "arn:aws:secretsmanager:us-east-1:01234567890:secret:MyBrokerSecretName".
    type "BASIC_AUTH" | "VPC_SUBNET" | "VPC_SECURITY_GROUP" | "SASL_SCRAM_512_AUTH" | "SASL_SCRAM_256_AUTH" | "VIRTUAL_HOST" | "CLIENT_CERTIFICATE_TLS_AUTH" | "SERVER_ROOT_CA_CERTIFICATE"
    The type of authentication protocol, VPC components, or virtual host for your event source. For example: "Type":"SASL_SCRAM_512_AUTH".

    • BASIC_AUTH – (Amazon MQ) The ASMlong secret that stores your broker credentials.
    • BASIC_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL/PLAIN authentication of your Apache Kafka brokers.
    • VPC_SUBNET – (Self-managed Apache Kafka) The subnets associated with your VPC. Lambda connects to these subnets to fetch data from your self-managed Apache Kafka cluster.
    • VPC_SECURITY_GROUP – (Self-managed Apache Kafka) The VPC security group used to manage access to your self-managed Apache Kafka brokers.
    • SASL_SCRAM_256_AUTH – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-256 authentication of your self-managed Apache Kafka brokers.
    • SASL_SCRAM_512_AUTH – (Amazon MSK, Self-managed Apache Kafka) The Secrets Manager ARN of your secret key used for SASL SCRAM-512 authentication of your self-managed Apache Kafka brokers.
    • VIRTUAL_HOST –- (RabbitMQ) The name of the virtual host in your RabbitMQ broker. Lambda uses this RabbitMQ host as the event source. This property cannot be specified in an UpdateEventSourceMapping API call.
    • CLIENT_CERTIFICATE_TLS_AUTH – (Amazon MSK, self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the certificate chain (X.509 PEM), private key (PKCS#8 PEM), and private key password (optional) used for mutual TLS authentication of your MSK/Apache Kafka brokers.
    • SERVER_ROOT_CA_CERTIFICATE – (Self-managed Apache Kafka) The Secrets Manager ARN of your secret key containing the root CA certificate (X.509 PEM) used for TLS encryption of your Apache Kafka brokers.
    uri String
    The value for your chosen configuration in Type. For example: "URI": "arn:aws:secretsmanager:us-east-1:01234567890:secret:MyBrokerSecretName".

    EventSourceMappingSourceAccessConfigurationType, EventSourceMappingSourceAccessConfigurationTypeArgs

    BasicAuth
    BASIC_AUTH
    VpcSubnet
    VPC_SUBNET
    VpcSecurityGroup
    VPC_SECURITY_GROUP
    SaslScram512Auth
    SASL_SCRAM_512_AUTH
    SaslScram256Auth
    SASL_SCRAM_256_AUTH
    VirtualHost
    VIRTUAL_HOST
    ClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    ServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    EventSourceMappingSourceAccessConfigurationTypeBasicAuth
    BASIC_AUTH
    EventSourceMappingSourceAccessConfigurationTypeVpcSubnet
    VPC_SUBNET
    EventSourceMappingSourceAccessConfigurationTypeVpcSecurityGroup
    VPC_SECURITY_GROUP
    EventSourceMappingSourceAccessConfigurationTypeSaslScram512Auth
    SASL_SCRAM_512_AUTH
    EventSourceMappingSourceAccessConfigurationTypeSaslScram256Auth
    SASL_SCRAM_256_AUTH
    EventSourceMappingSourceAccessConfigurationTypeVirtualHost
    VIRTUAL_HOST
    EventSourceMappingSourceAccessConfigurationTypeClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    EventSourceMappingSourceAccessConfigurationTypeServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    BasicAuth
    BASIC_AUTH
    VpcSubnet
    VPC_SUBNET
    VpcSecurityGroup
    VPC_SECURITY_GROUP
    SaslScram512Auth
    SASL_SCRAM_512_AUTH
    SaslScram256Auth
    SASL_SCRAM_256_AUTH
    VirtualHost
    VIRTUAL_HOST
    ClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    ServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    BasicAuth
    BASIC_AUTH
    VpcSubnet
    VPC_SUBNET
    VpcSecurityGroup
    VPC_SECURITY_GROUP
    SaslScram512Auth
    SASL_SCRAM_512_AUTH
    SaslScram256Auth
    SASL_SCRAM_256_AUTH
    VirtualHost
    VIRTUAL_HOST
    ClientCertificateTlsAuth
    CLIENT_CERTIFICATE_TLS_AUTH
    ServerRootCaCertificate
    SERVER_ROOT_CA_CERTIFICATE
    BASIC_AUTH
    BASIC_AUTH
    VPC_SUBNET
    VPC_SUBNET
    VPC_SECURITY_GROUP
    VPC_SECURITY_GROUP
    SASL_SCRAM512_AUTH
    SASL_SCRAM_512_AUTH
    SASL_SCRAM256_AUTH
    SASL_SCRAM_256_AUTH
    VIRTUAL_HOST
    VIRTUAL_HOST
    CLIENT_CERTIFICATE_TLS_AUTH
    CLIENT_CERTIFICATE_TLS_AUTH
    SERVER_ROOT_CA_CERTIFICATE
    SERVER_ROOT_CA_CERTIFICATE
    "BASIC_AUTH"
    BASIC_AUTH
    "VPC_SUBNET"
    VPC_SUBNET
    "VPC_SECURITY_GROUP"
    VPC_SECURITY_GROUP
    "SASL_SCRAM_512_AUTH"
    SASL_SCRAM_512_AUTH
    "SASL_SCRAM_256_AUTH"
    SASL_SCRAM_256_AUTH
    "VIRTUAL_HOST"
    VIRTUAL_HOST
    "CLIENT_CERTIFICATE_TLS_AUTH"
    CLIENT_CERTIFICATE_TLS_AUTH
    "SERVER_ROOT_CA_CERTIFICATE"
    SERVER_ROOT_CA_CERTIFICATE

    Tag, TagArgs

    A set of tags to apply to the resource.
    Key string
    The key name of the tag
    Value string
    The value of the tag
    Key string
    The key name of the tag
    Value string
    The value of the tag
    key String
    The key name of the tag
    value String
    The value of the tag
    key string
    The key name of the tag
    value string
    The value of the tag
    key str
    The key name of the tag
    value str
    The value of the tag
    key String
    The key name of the tag
    value String
    The value of the tag

    Package Details

    Repository
    AWS Native pulumi/pulumi-aws-native
    License
    Apache-2.0
    aws-native logo

    We recommend new projects start with resources from the AWS provider.

    AWS Cloud Control v1.37.0 published on Wednesday, Oct 15, 2025 by Pulumi
    pulumi/pulumi-aws-native
      Meet Neo: Your AI Platform Teammate