/* * Copyright 2018-2023 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with * the License. A copy of the License is located at * * http://aws.amazon.com/apache2.0 * * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions * and limitations under the License. */ package com.amazonaws.services.lambda.model; import java.io.Serializable; import javax.annotation.Generated; import com.amazonaws.AmazonWebServiceRequest; /** * * @see AWS * API Documentation */ @Generated("com.amazonaws:aws-java-sdk-code-generator") public class CreateEventSourceMappingRequest extends com.amazonaws.AmazonWebServiceRequest implements Serializable, Cloneable { /** *

* The Amazon Resource Name (ARN) of the event source. *

* */ private String eventSourceArn; /** *

* The name of the Lambda function. *

*

* Name formats *

* *

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

*/ private String functionName; /** *

* When true, the event source mapping is active. When false, Lambda pauses polling and invocation. *

*

* Default: True *

*/ private Boolean enabled; /** *

* 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). *

* */ private Integer batchSize; /** *

* An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda * event filtering. *

*/ private FilterCriteria filterCriteria; /** *

* The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. You * can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds in * increments of seconds. *

*

* For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, Self-managed * Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. Note that because * you can only change MaximumBatchingWindowInSeconds in increments of seconds, you cannot revert back * to the 500 ms default batching window after you have changed it. To restore the default batching window, you must * create a new event source mapping. *

*

* Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value greater * than 10, you must set MaximumBatchingWindowInSeconds to at least 1. *

*/ private Integer maximumBatchingWindowInSeconds; /** *

* (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. *

*/ private Integer parallelizationFactor; /** *

* The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Stream * event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon DocumentDB, Amazon * MSK, and self-managed Apache Kafka. *

*/ private String startingPosition; /** *

* With StartingPosition set to AT_TIMESTAMP, the time from which to start reading. * StartingPositionTimestamp cannot be in the future. *

*/ private java.util.Date startingPositionTimestamp; /** *

* (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination for * discarded records. *

*/ private DestinationConfig destinationConfig; /** *

* (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is infinite * (-1). *

*/ private Integer maximumRecordAgeInSeconds; /** *

* (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. *

*/ private Boolean bisectBatchOnFunctionError; /** *

* (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is * infinite (-1). When set to infinite (-1), failed records are retried until the record expires. *

*/ private Integer maximumRetryAttempts; /** *

* (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. *

*/ private Integer tumblingWindowInSeconds; /** *

* The name of the Kafka topic. *

*/ private com.amazonaws.internal.SdkInternalList topics; /** *

* (MQ) The name of the Amazon MQ broker destination queue to consume. *

*/ private com.amazonaws.internal.SdkInternalList queues; /** *

* An array of authentication protocols or VPC components required to secure your event source. *

*/ private com.amazonaws.internal.SdkInternalList sourceAccessConfigurations; /** *

* The self-managed Apache Kafka cluster to receive records from. *

*/ private SelfManagedEventSource selfManagedEventSource; /** *

* (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *

*/ private com.amazonaws.internal.SdkInternalList functionResponseTypes; /** *

* Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source. *

*/ private AmazonManagedKafkaEventSourceConfig amazonManagedKafkaEventSourceConfig; /** *

* Specific configuration settings for a self-managed Apache Kafka event source. *

*/ private SelfManagedKafkaEventSourceConfig selfManagedKafkaEventSourceConfig; /** *

* (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum * concurrency for Amazon SQS event sources. *

*/ private ScalingConfig scalingConfig; /** *

* Specific configuration settings for a DocumentDB event source. *

*/ private DocumentDBEventSourceConfig documentDBEventSourceConfig; /** *

* 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. *

    *
    • *
  • *

    * Amazon MQ – The ARN of the broker. *

    *
    • *
  • *

    * Amazon DocumentDB – The ARN of the DocumentDB change stream. *

    *
    • *
* * @param eventSourceArn * 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. *

    *
    • *
  • *

    * Amazon MQ – The ARN of the broker. *

    *
    • *
  • *

    * Amazon DocumentDB – The ARN of the DocumentDB change stream. *

    *
    • */ public void setEventSourceArn(String eventSourceArn) { this.eventSourceArn = eventSourceArn; } /** *

    * 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. *

      *
      • *
    • *

      * Amazon MQ – The ARN of the broker. *

      *
      • *
    • *

      * Amazon DocumentDB – The ARN of the DocumentDB change stream. *

      *
      • *
    * * @return 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. *

      *
      • *
    • *

      * Amazon MQ – The ARN of the broker. *

      *
      • *
    • *

      * Amazon DocumentDB – The ARN of the DocumentDB change stream. *

      *
      • */ public String getEventSourceArn() { return this.eventSourceArn; } /** *

      * 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. *

        *
        • *
      • *

        * Amazon MQ – The ARN of the broker. *

        *
        • *
      • *

        * Amazon DocumentDB – The ARN of the DocumentDB change stream. *

        *
        • *
      * * @param eventSourceArn * 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. *

        *
        • *
      • *

        * Amazon MQ – The ARN of the broker. *

        *
        • *
      • *

        * Amazon DocumentDB – The ARN of the DocumentDB change stream. *

        *
        • * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withEventSourceArn(String eventSourceArn) { setEventSourceArn(eventSourceArn); return this; } /** *

        * The name 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. *

        * * @param functionName * The name 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. */ public void setFunctionName(String functionName) { this.functionName = functionName; } /** *

        * The name 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. *

        * * @return The name 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. */ public String getFunctionName() { return this.functionName; } /** *

        * The name 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. *

        * * @param functionName * The name 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. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withFunctionName(String functionName) { setFunctionName(functionName); return this; } /** *

        * When true, the event source mapping is active. When false, Lambda pauses polling and invocation. *

        *

        * Default: True *

        * * @param enabled * When true, the event source mapping is active. When false, Lambda pauses polling and invocation.

        *

        * Default: True */ public void setEnabled(Boolean enabled) { this.enabled = enabled; } /** *

        * When true, the event source mapping is active. When false, Lambda pauses polling and invocation. *

        *

        * Default: True *

        * * @return When true, the event source mapping is active. When false, Lambda pauses polling and invocation.

        *

        * Default: True */ public Boolean getEnabled() { return this.enabled; } /** *

        * When true, the event source mapping is active. When false, Lambda pauses polling and invocation. *

        *

        * Default: True *

        * * @param enabled * When true, the event source mapping is active. When false, Lambda pauses polling and invocation.

        *

        * Default: True * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withEnabled(Boolean enabled) { setEnabled(enabled); return this; } /** *

        * When true, the event source mapping is active. When false, Lambda pauses polling and invocation. *

        *

        * Default: True *

        * * @return When true, the event source mapping is active. When false, Lambda pauses polling and invocation.

        *

        * Default: True */ public Boolean isEnabled() { return this.enabled; } /** *

        * 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. *

          *
          • *
        * * @param batchSize * 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. *

          *
          • */ public void setBatchSize(Integer batchSize) { this.batchSize = batchSize; } /** *

          * 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. *

            *
            • *
          * * @return 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. *

            *
            • */ public Integer getBatchSize() { return this.batchSize; } /** *

            * 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. *

              *
              • *
            * * @param batchSize * 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. *

              *
              • * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withBatchSize(Integer batchSize) { setBatchSize(batchSize); return this; } /** *

              * An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda * event filtering. *

              * * @param filterCriteria * An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda event * filtering. */ public void setFilterCriteria(FilterCriteria filterCriteria) { this.filterCriteria = filterCriteria; } /** *

              * An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda * event filtering. *

              * * @return An object that defines the filter criteria that determine whether Lambda should process an event. For * more information, see Lambda event * filtering. */ public FilterCriteria getFilterCriteria() { return this.filterCriteria; } /** *

              * An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda * event filtering. *

              * * @param filterCriteria * An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda event * filtering. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withFilterCriteria(FilterCriteria filterCriteria) { setFilterCriteria(filterCriteria); return this; } /** *

              * The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. You * can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds in * increments of seconds. *

              *

              * For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, Self-managed * Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. Note that because * you can only change MaximumBatchingWindowInSeconds in increments of seconds, you cannot revert back * to the 500 ms default batching window after you have changed it. To restore the default batching window, you must * create a new event source mapping. *

              *

              * Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value greater * than 10, you must set MaximumBatchingWindowInSeconds to at least 1. *

              * * @param maximumBatchingWindowInSeconds * The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. * You can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds * in increments of seconds.

              *

              * For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, * Self-managed Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. * Note that because you can only change MaximumBatchingWindowInSeconds in increments of * seconds, you cannot revert back to the 500 ms default batching window after you have changed it. To * restore the default batching window, you must create a new event source mapping. *

              *

              * Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value * greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1. */ public void setMaximumBatchingWindowInSeconds(Integer maximumBatchingWindowInSeconds) { this.maximumBatchingWindowInSeconds = maximumBatchingWindowInSeconds; } /** *

              * The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. You * can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds in * increments of seconds. *

              *

              * For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, Self-managed * Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. Note that because * you can only change MaximumBatchingWindowInSeconds in increments of seconds, you cannot revert back * to the 500 ms default batching window after you have changed it. To restore the default batching window, you must * create a new event source mapping. *

              *

              * Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value greater * than 10, you must set MaximumBatchingWindowInSeconds to at least 1. *

              * * @return The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the * function. You can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to * 300 seconds in increments of seconds.

              *

              * For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, * Self-managed Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 * ms. Note that because you can only change MaximumBatchingWindowInSeconds in increments of * seconds, you cannot revert back to the 500 ms default batching window after you have changed it. To * restore the default batching window, you must create a new event source mapping. *

              *

              * Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value * greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1. */ public Integer getMaximumBatchingWindowInSeconds() { return this.maximumBatchingWindowInSeconds; } /** *

              * The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. You * can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds in * increments of seconds. *

              *

              * For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, Self-managed * Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. Note that because * you can only change MaximumBatchingWindowInSeconds in increments of seconds, you cannot revert back * to the 500 ms default batching window after you have changed it. To restore the default batching window, you must * create a new event source mapping. *

              *

              * Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value greater * than 10, you must set MaximumBatchingWindowInSeconds to at least 1. *

              * * @param maximumBatchingWindowInSeconds * The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. * You can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds * in increments of seconds.

              *

              * For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, * Self-managed Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. * Note that because you can only change MaximumBatchingWindowInSeconds in increments of * seconds, you cannot revert back to the 500 ms default batching window after you have changed it. To * restore the default batching window, you must create a new event source mapping. *

              *

              * Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value * greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withMaximumBatchingWindowInSeconds(Integer maximumBatchingWindowInSeconds) { setMaximumBatchingWindowInSeconds(maximumBatchingWindowInSeconds); return this; } /** *

              * (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. *

              * * @param parallelizationFactor * (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. */ public void setParallelizationFactor(Integer parallelizationFactor) { this.parallelizationFactor = parallelizationFactor; } /** *

              * (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. *

              * * @return (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. */ public Integer getParallelizationFactor() { return this.parallelizationFactor; } /** *

              * (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. *

              * * @param parallelizationFactor * (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withParallelizationFactor(Integer parallelizationFactor) { setParallelizationFactor(parallelizationFactor); return this; } /** *

              * The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Stream * event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon DocumentDB, Amazon * MSK, and self-managed Apache Kafka. *

              * * @param startingPosition * The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB * Stream event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon * DocumentDB, Amazon MSK, and self-managed Apache Kafka. * @see EventSourcePosition */ public void setStartingPosition(String startingPosition) { this.startingPosition = startingPosition; } /** *

              * The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Stream * event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon DocumentDB, Amazon * MSK, and self-managed Apache Kafka. *

              * * @return The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB * Stream event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon * DocumentDB, Amazon MSK, and self-managed Apache Kafka. * @see EventSourcePosition */ public String getStartingPosition() { return this.startingPosition; } /** *

              * The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Stream * event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon DocumentDB, Amazon * MSK, and self-managed Apache Kafka. *

              * * @param startingPosition * The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB * Stream event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon * DocumentDB, Amazon MSK, and self-managed Apache Kafka. * @return Returns a reference to this object so that method calls can be chained together. * @see EventSourcePosition */ public CreateEventSourceMappingRequest withStartingPosition(String startingPosition) { setStartingPosition(startingPosition); return this; } /** *

              * The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Stream * event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon DocumentDB, Amazon * MSK, and self-managed Apache Kafka. *

              * * @param startingPosition * The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB * Stream event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon * DocumentDB, Amazon MSK, and self-managed Apache Kafka. * @see EventSourcePosition */ public void setStartingPosition(EventSourcePosition startingPosition) { withStartingPosition(startingPosition); } /** *

              * The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Stream * event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon DocumentDB, Amazon * MSK, and self-managed Apache Kafka. *

              * * @param startingPosition * The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB * Stream event sources. AT_TIMESTAMP is supported only for Amazon Kinesis streams, Amazon * DocumentDB, Amazon MSK, and self-managed Apache Kafka. * @return Returns a reference to this object so that method calls can be chained together. * @see EventSourcePosition */ public CreateEventSourceMappingRequest withStartingPosition(EventSourcePosition startingPosition) { this.startingPosition = startingPosition.toString(); return this; } /** *

              * With StartingPosition set to AT_TIMESTAMP, the time from which to start reading. * StartingPositionTimestamp cannot be in the future. *

              * * @param startingPositionTimestamp * With StartingPosition set to AT_TIMESTAMP, the time from which to start reading. * StartingPositionTimestamp cannot be in the future. */ public void setStartingPositionTimestamp(java.util.Date startingPositionTimestamp) { this.startingPositionTimestamp = startingPositionTimestamp; } /** *

              * With StartingPosition set to AT_TIMESTAMP, the time from which to start reading. * StartingPositionTimestamp cannot be in the future. *

              * * @return With StartingPosition set to AT_TIMESTAMP, the time from which to start * reading. StartingPositionTimestamp cannot be in the future. */ public java.util.Date getStartingPositionTimestamp() { return this.startingPositionTimestamp; } /** *

              * With StartingPosition set to AT_TIMESTAMP, the time from which to start reading. * StartingPositionTimestamp cannot be in the future. *

              * * @param startingPositionTimestamp * With StartingPosition set to AT_TIMESTAMP, the time from which to start reading. * StartingPositionTimestamp cannot be in the future. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withStartingPositionTimestamp(java.util.Date startingPositionTimestamp) { setStartingPositionTimestamp(startingPositionTimestamp); return this; } /** *

              * (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination for * discarded records. *

              * * @param destinationConfig * (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination * for discarded records. */ public void setDestinationConfig(DestinationConfig destinationConfig) { this.destinationConfig = destinationConfig; } /** *

              * (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination for * discarded records. *

              * * @return (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination * for discarded records. */ public DestinationConfig getDestinationConfig() { return this.destinationConfig; } /** *

              * (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination for * discarded records. *

              * * @param destinationConfig * (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination * for discarded records. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withDestinationConfig(DestinationConfig destinationConfig) { setDestinationConfig(destinationConfig); return this; } /** *

              * (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is infinite * (-1). *

              * * @param maximumRecordAgeInSeconds * (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is * infinite (-1). */ public void setMaximumRecordAgeInSeconds(Integer maximumRecordAgeInSeconds) { this.maximumRecordAgeInSeconds = maximumRecordAgeInSeconds; } /** *

              * (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is infinite * (-1). *

              * * @return (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is * infinite (-1). */ public Integer getMaximumRecordAgeInSeconds() { return this.maximumRecordAgeInSeconds; } /** *

              * (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is infinite * (-1). *

              * * @param maximumRecordAgeInSeconds * (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is * infinite (-1). * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withMaximumRecordAgeInSeconds(Integer maximumRecordAgeInSeconds) { setMaximumRecordAgeInSeconds(maximumRecordAgeInSeconds); return this; } /** *

              * (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. *

              * * @param bisectBatchOnFunctionError * (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. */ public void setBisectBatchOnFunctionError(Boolean bisectBatchOnFunctionError) { this.bisectBatchOnFunctionError = bisectBatchOnFunctionError; } /** *

              * (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. *

              * * @return (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. */ public Boolean getBisectBatchOnFunctionError() { return this.bisectBatchOnFunctionError; } /** *

              * (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. *

              * * @param bisectBatchOnFunctionError * (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withBisectBatchOnFunctionError(Boolean bisectBatchOnFunctionError) { setBisectBatchOnFunctionError(bisectBatchOnFunctionError); return this; } /** *

              * (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. *

              * * @return (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. */ public Boolean isBisectBatchOnFunctionError() { return this.bisectBatchOnFunctionError; } /** *

              * (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is * infinite (-1). When set to infinite (-1), failed records are retried until the record expires. *

              * * @param maximumRetryAttempts * (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default * value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires. */ public void setMaximumRetryAttempts(Integer maximumRetryAttempts) { this.maximumRetryAttempts = maximumRetryAttempts; } /** *

              * (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is * infinite (-1). When set to infinite (-1), failed records are retried until the record expires. *

              * * @return (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default * value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires. */ public Integer getMaximumRetryAttempts() { return this.maximumRetryAttempts; } /** *

              * (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is * infinite (-1). When set to infinite (-1), failed records are retried until the record expires. *

              * * @param maximumRetryAttempts * (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default * value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withMaximumRetryAttempts(Integer maximumRetryAttempts) { setMaximumRetryAttempts(maximumRetryAttempts); return this; } /** *

              * (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. *

              * * @param tumblingWindowInSeconds * (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. */ public void setTumblingWindowInSeconds(Integer tumblingWindowInSeconds) { this.tumblingWindowInSeconds = tumblingWindowInSeconds; } /** *

              * (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. *

              * * @return (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. */ public Integer getTumblingWindowInSeconds() { return this.tumblingWindowInSeconds; } /** *

              * (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. *

              * * @param tumblingWindowInSeconds * (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. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withTumblingWindowInSeconds(Integer tumblingWindowInSeconds) { setTumblingWindowInSeconds(tumblingWindowInSeconds); return this; } /** *

              * The name of the Kafka topic. *

              * * @return The name of the Kafka topic. */ public java.util.List getTopics() { if (topics == null) { topics = new com.amazonaws.internal.SdkInternalList(); } return topics; } /** *

              * The name of the Kafka topic. *

              * * @param topics * The name of the Kafka topic. */ public void setTopics(java.util.Collection topics) { if (topics == null) { this.topics = null; return; } this.topics = new com.amazonaws.internal.SdkInternalList(topics); } /** *

              * The name of the Kafka topic. *

              *

              * NOTE: This method appends the values to the existing list (if any). Use * {@link #setTopics(java.util.Collection)} or {@link #withTopics(java.util.Collection)} if you want to override the * existing values. *

              * * @param topics * The name of the Kafka topic. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withTopics(String... topics) { if (this.topics == null) { setTopics(new com.amazonaws.internal.SdkInternalList(topics.length)); } for (String ele : topics) { this.topics.add(ele); } return this; } /** *

              * The name of the Kafka topic. *

              * * @param topics * The name of the Kafka topic. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withTopics(java.util.Collection topics) { setTopics(topics); return this; } /** *

              * (MQ) The name of the Amazon MQ broker destination queue to consume. *

              * * @return (MQ) The name of the Amazon MQ broker destination queue to consume. */ public java.util.List getQueues() { if (queues == null) { queues = new com.amazonaws.internal.SdkInternalList(); } return queues; } /** *

              * (MQ) The name of the Amazon MQ broker destination queue to consume. *

              * * @param queues * (MQ) The name of the Amazon MQ broker destination queue to consume. */ public void setQueues(java.util.Collection queues) { if (queues == null) { this.queues = null; return; } this.queues = new com.amazonaws.internal.SdkInternalList(queues); } /** *

              * (MQ) The name of the Amazon MQ broker destination queue to consume. *

              *

              * NOTE: This method appends the values to the existing list (if any). Use * {@link #setQueues(java.util.Collection)} or {@link #withQueues(java.util.Collection)} if you want to override the * existing values. *

              * * @param queues * (MQ) The name of the Amazon MQ broker destination queue to consume. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withQueues(String... queues) { if (this.queues == null) { setQueues(new com.amazonaws.internal.SdkInternalList(queues.length)); } for (String ele : queues) { this.queues.add(ele); } return this; } /** *

              * (MQ) The name of the Amazon MQ broker destination queue to consume. *

              * * @param queues * (MQ) The name of the Amazon MQ broker destination queue to consume. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withQueues(java.util.Collection queues) { setQueues(queues); return this; } /** *

              * An array of authentication protocols or VPC components required to secure your event source. *

              * * @return An array of authentication protocols or VPC components required to secure your event source. */ public java.util.List getSourceAccessConfigurations() { if (sourceAccessConfigurations == null) { sourceAccessConfigurations = new com.amazonaws.internal.SdkInternalList(); } return sourceAccessConfigurations; } /** *

              * An array of authentication protocols or VPC components required to secure your event source. *

              * * @param sourceAccessConfigurations * An array of authentication protocols or VPC components required to secure your event source. */ public void setSourceAccessConfigurations(java.util.Collection sourceAccessConfigurations) { if (sourceAccessConfigurations == null) { this.sourceAccessConfigurations = null; return; } this.sourceAccessConfigurations = new com.amazonaws.internal.SdkInternalList(sourceAccessConfigurations); } /** *

              * An array of authentication protocols or VPC components required to secure your event source. *

              *

              * NOTE: This method appends the values to the existing list (if any). Use * {@link #setSourceAccessConfigurations(java.util.Collection)} or * {@link #withSourceAccessConfigurations(java.util.Collection)} if you want to override the existing values. *

              * * @param sourceAccessConfigurations * An array of authentication protocols or VPC components required to secure your event source. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withSourceAccessConfigurations(SourceAccessConfiguration... sourceAccessConfigurations) { if (this.sourceAccessConfigurations == null) { setSourceAccessConfigurations(new com.amazonaws.internal.SdkInternalList(sourceAccessConfigurations.length)); } for (SourceAccessConfiguration ele : sourceAccessConfigurations) { this.sourceAccessConfigurations.add(ele); } return this; } /** *

              * An array of authentication protocols or VPC components required to secure your event source. *

              * * @param sourceAccessConfigurations * An array of authentication protocols or VPC components required to secure your event source. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withSourceAccessConfigurations(java.util.Collection sourceAccessConfigurations) { setSourceAccessConfigurations(sourceAccessConfigurations); return this; } /** *

              * The self-managed Apache Kafka cluster to receive records from. *

              * * @param selfManagedEventSource * The self-managed Apache Kafka cluster to receive records from. */ public void setSelfManagedEventSource(SelfManagedEventSource selfManagedEventSource) { this.selfManagedEventSource = selfManagedEventSource; } /** *

              * The self-managed Apache Kafka cluster to receive records from. *

              * * @return The self-managed Apache Kafka cluster to receive records from. */ public SelfManagedEventSource getSelfManagedEventSource() { return this.selfManagedEventSource; } /** *

              * The self-managed Apache Kafka cluster to receive records from. *

              * * @param selfManagedEventSource * The self-managed Apache Kafka cluster to receive records from. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withSelfManagedEventSource(SelfManagedEventSource selfManagedEventSource) { setSelfManagedEventSource(selfManagedEventSource); return this; } /** *

              * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *

              * * @return (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event * source mapping. * @see FunctionResponseType */ public java.util.List getFunctionResponseTypes() { if (functionResponseTypes == null) { functionResponseTypes = new com.amazonaws.internal.SdkInternalList(); } return functionResponseTypes; } /** *

              * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *

              * * @param functionResponseTypes * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event * source mapping. * @see FunctionResponseType */ public void setFunctionResponseTypes(java.util.Collection functionResponseTypes) { if (functionResponseTypes == null) { this.functionResponseTypes = null; return; } this.functionResponseTypes = new com.amazonaws.internal.SdkInternalList(functionResponseTypes); } /** *

              * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *

              *

              * NOTE: This method appends the values to the existing list (if any). Use * {@link #setFunctionResponseTypes(java.util.Collection)} or * {@link #withFunctionResponseTypes(java.util.Collection)} if you want to override the existing values. *

              * * @param functionResponseTypes * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event * source mapping. * @return Returns a reference to this object so that method calls can be chained together. * @see FunctionResponseType */ public CreateEventSourceMappingRequest withFunctionResponseTypes(String... functionResponseTypes) { if (this.functionResponseTypes == null) { setFunctionResponseTypes(new com.amazonaws.internal.SdkInternalList(functionResponseTypes.length)); } for (String ele : functionResponseTypes) { this.functionResponseTypes.add(ele); } return this; } /** *

              * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *

              * * @param functionResponseTypes * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event * source mapping. * @return Returns a reference to this object so that method calls can be chained together. * @see FunctionResponseType */ public CreateEventSourceMappingRequest withFunctionResponseTypes(java.util.Collection functionResponseTypes) { setFunctionResponseTypes(functionResponseTypes); return this; } /** *

              * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *

              * * @param functionResponseTypes * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event * source mapping. * @return Returns a reference to this object so that method calls can be chained together. * @see FunctionResponseType */ public CreateEventSourceMappingRequest withFunctionResponseTypes(FunctionResponseType... functionResponseTypes) { com.amazonaws.internal.SdkInternalList functionResponseTypesCopy = new com.amazonaws.internal.SdkInternalList( functionResponseTypes.length); for (FunctionResponseType value : functionResponseTypes) { functionResponseTypesCopy.add(value.toString()); } if (getFunctionResponseTypes() == null) { setFunctionResponseTypes(functionResponseTypesCopy); } else { getFunctionResponseTypes().addAll(functionResponseTypesCopy); } return this; } /** *

              * Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source. *

              * * @param amazonManagedKafkaEventSourceConfig * Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event * source. */ public void setAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfig amazonManagedKafkaEventSourceConfig) { this.amazonManagedKafkaEventSourceConfig = amazonManagedKafkaEventSourceConfig; } /** *

              * Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source. *

              * * @return Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event * source. */ public AmazonManagedKafkaEventSourceConfig getAmazonManagedKafkaEventSourceConfig() { return this.amazonManagedKafkaEventSourceConfig; } /** *

              * Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source. *

              * * @param amazonManagedKafkaEventSourceConfig * Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event * source. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withAmazonManagedKafkaEventSourceConfig(AmazonManagedKafkaEventSourceConfig amazonManagedKafkaEventSourceConfig) { setAmazonManagedKafkaEventSourceConfig(amazonManagedKafkaEventSourceConfig); return this; } /** *

              * Specific configuration settings for a self-managed Apache Kafka event source. *

              * * @param selfManagedKafkaEventSourceConfig * Specific configuration settings for a self-managed Apache Kafka event source. */ public void setSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfig selfManagedKafkaEventSourceConfig) { this.selfManagedKafkaEventSourceConfig = selfManagedKafkaEventSourceConfig; } /** *

              * Specific configuration settings for a self-managed Apache Kafka event source. *

              * * @return Specific configuration settings for a self-managed Apache Kafka event source. */ public SelfManagedKafkaEventSourceConfig getSelfManagedKafkaEventSourceConfig() { return this.selfManagedKafkaEventSourceConfig; } /** *

              * Specific configuration settings for a self-managed Apache Kafka event source. *

              * * @param selfManagedKafkaEventSourceConfig * Specific configuration settings for a self-managed Apache Kafka event source. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withSelfManagedKafkaEventSourceConfig(SelfManagedKafkaEventSourceConfig selfManagedKafkaEventSourceConfig) { setSelfManagedKafkaEventSourceConfig(selfManagedKafkaEventSourceConfig); return this; } /** *

              * (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum * concurrency for Amazon SQS event sources. *

              * * @param scalingConfig * (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring * maximum concurrency for Amazon SQS event sources. */ public void setScalingConfig(ScalingConfig scalingConfig) { this.scalingConfig = scalingConfig; } /** *

              * (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum * concurrency for Amazon SQS event sources. *

              * * @return (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring * maximum concurrency for Amazon SQS event sources. */ public ScalingConfig getScalingConfig() { return this.scalingConfig; } /** *

              * (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum * concurrency for Amazon SQS event sources. *

              * * @param scalingConfig * (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring * maximum concurrency for Amazon SQS event sources. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withScalingConfig(ScalingConfig scalingConfig) { setScalingConfig(scalingConfig); return this; } /** *

              * Specific configuration settings for a DocumentDB event source. *

              * * @param documentDBEventSourceConfig * Specific configuration settings for a DocumentDB event source. */ public void setDocumentDBEventSourceConfig(DocumentDBEventSourceConfig documentDBEventSourceConfig) { this.documentDBEventSourceConfig = documentDBEventSourceConfig; } /** *

              * Specific configuration settings for a DocumentDB event source. *

              * * @return Specific configuration settings for a DocumentDB event source. */ public DocumentDBEventSourceConfig getDocumentDBEventSourceConfig() { return this.documentDBEventSourceConfig; } /** *

              * Specific configuration settings for a DocumentDB event source. *

              * * @param documentDBEventSourceConfig * Specific configuration settings for a DocumentDB event source. * @return Returns a reference to this object so that method calls can be chained together. */ public CreateEventSourceMappingRequest withDocumentDBEventSourceConfig(DocumentDBEventSourceConfig documentDBEventSourceConfig) { setDocumentDBEventSourceConfig(documentDBEventSourceConfig); return this; } /** * Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be * redacted from this string using a placeholder value. * * @return A string representation of this object. * * @see java.lang.Object#toString() */ @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("{"); if (getEventSourceArn() != null) sb.append("EventSourceArn: ").append(getEventSourceArn()).append(","); if (getFunctionName() != null) sb.append("FunctionName: ").append(getFunctionName()).append(","); if (getEnabled() != null) sb.append("Enabled: ").append(getEnabled()).append(","); if (getBatchSize() != null) sb.append("BatchSize: ").append(getBatchSize()).append(","); if (getFilterCriteria() != null) sb.append("FilterCriteria: ").append(getFilterCriteria()).append(","); if (getMaximumBatchingWindowInSeconds() != null) sb.append("MaximumBatchingWindowInSeconds: ").append(getMaximumBatchingWindowInSeconds()).append(","); if (getParallelizationFactor() != null) sb.append("ParallelizationFactor: ").append(getParallelizationFactor()).append(","); if (getStartingPosition() != null) sb.append("StartingPosition: ").append(getStartingPosition()).append(","); if (getStartingPositionTimestamp() != null) sb.append("StartingPositionTimestamp: ").append(getStartingPositionTimestamp()).append(","); if (getDestinationConfig() != null) sb.append("DestinationConfig: ").append(getDestinationConfig()).append(","); if (getMaximumRecordAgeInSeconds() != null) sb.append("MaximumRecordAgeInSeconds: ").append(getMaximumRecordAgeInSeconds()).append(","); if (getBisectBatchOnFunctionError() != null) sb.append("BisectBatchOnFunctionError: ").append(getBisectBatchOnFunctionError()).append(","); if (getMaximumRetryAttempts() != null) sb.append("MaximumRetryAttempts: ").append(getMaximumRetryAttempts()).append(","); if (getTumblingWindowInSeconds() != null) sb.append("TumblingWindowInSeconds: ").append(getTumblingWindowInSeconds()).append(","); if (getTopics() != null) sb.append("Topics: ").append(getTopics()).append(","); if (getQueues() != null) sb.append("Queues: ").append(getQueues()).append(","); if (getSourceAccessConfigurations() != null) sb.append("SourceAccessConfigurations: ").append(getSourceAccessConfigurations()).append(","); if (getSelfManagedEventSource() != null) sb.append("SelfManagedEventSource: ").append(getSelfManagedEventSource()).append(","); if (getFunctionResponseTypes() != null) sb.append("FunctionResponseTypes: ").append(getFunctionResponseTypes()).append(","); if (getAmazonManagedKafkaEventSourceConfig() != null) sb.append("AmazonManagedKafkaEventSourceConfig: ").append(getAmazonManagedKafkaEventSourceConfig()).append(","); if (getSelfManagedKafkaEventSourceConfig() != null) sb.append("SelfManagedKafkaEventSourceConfig: ").append(getSelfManagedKafkaEventSourceConfig()).append(","); if (getScalingConfig() != null) sb.append("ScalingConfig: ").append(getScalingConfig()).append(","); if (getDocumentDBEventSourceConfig() != null) sb.append("DocumentDBEventSourceConfig: ").append(getDocumentDBEventSourceConfig()); sb.append("}"); return sb.toString(); } @Override public boolean equals(Object obj) { if (this == obj) return true; if (obj == null) return false; if (obj instanceof CreateEventSourceMappingRequest == false) return false; CreateEventSourceMappingRequest other = (CreateEventSourceMappingRequest) obj; if (other.getEventSourceArn() == null ^ this.getEventSourceArn() == null) return false; if (other.getEventSourceArn() != null && other.getEventSourceArn().equals(this.getEventSourceArn()) == false) return false; if (other.getFunctionName() == null ^ this.getFunctionName() == null) return false; if (other.getFunctionName() != null && other.getFunctionName().equals(this.getFunctionName()) == false) return false; if (other.getEnabled() == null ^ this.getEnabled() == null) return false; if (other.getEnabled() != null && other.getEnabled().equals(this.getEnabled()) == false) return false; if (other.getBatchSize() == null ^ this.getBatchSize() == null) return false; if (other.getBatchSize() != null && other.getBatchSize().equals(this.getBatchSize()) == false) return false; if (other.getFilterCriteria() == null ^ this.getFilterCriteria() == null) return false; if (other.getFilterCriteria() != null && other.getFilterCriteria().equals(this.getFilterCriteria()) == false) return false; if (other.getMaximumBatchingWindowInSeconds() == null ^ this.getMaximumBatchingWindowInSeconds() == null) return false; if (other.getMaximumBatchingWindowInSeconds() != null && other.getMaximumBatchingWindowInSeconds().equals(this.getMaximumBatchingWindowInSeconds()) == false) return false; if (other.getParallelizationFactor() == null ^ this.getParallelizationFactor() == null) return false; if (other.getParallelizationFactor() != null && other.getParallelizationFactor().equals(this.getParallelizationFactor()) == false) return false; if (other.getStartingPosition() == null ^ this.getStartingPosition() == null) return false; if (other.getStartingPosition() != null && other.getStartingPosition().equals(this.getStartingPosition()) == false) return false; if (other.getStartingPositionTimestamp() == null ^ this.getStartingPositionTimestamp() == null) return false; if (other.getStartingPositionTimestamp() != null && other.getStartingPositionTimestamp().equals(this.getStartingPositionTimestamp()) == false) return false; if (other.getDestinationConfig() == null ^ this.getDestinationConfig() == null) return false; if (other.getDestinationConfig() != null && other.getDestinationConfig().equals(this.getDestinationConfig()) == false) return false; if (other.getMaximumRecordAgeInSeconds() == null ^ this.getMaximumRecordAgeInSeconds() == null) return false; if (other.getMaximumRecordAgeInSeconds() != null && other.getMaximumRecordAgeInSeconds().equals(this.getMaximumRecordAgeInSeconds()) == false) return false; if (other.getBisectBatchOnFunctionError() == null ^ this.getBisectBatchOnFunctionError() == null) return false; if (other.getBisectBatchOnFunctionError() != null && other.getBisectBatchOnFunctionError().equals(this.getBisectBatchOnFunctionError()) == false) return false; if (other.getMaximumRetryAttempts() == null ^ this.getMaximumRetryAttempts() == null) return false; if (other.getMaximumRetryAttempts() != null && other.getMaximumRetryAttempts().equals(this.getMaximumRetryAttempts()) == false) return false; if (other.getTumblingWindowInSeconds() == null ^ this.getTumblingWindowInSeconds() == null) return false; if (other.getTumblingWindowInSeconds() != null && other.getTumblingWindowInSeconds().equals(this.getTumblingWindowInSeconds()) == false) return false; if (other.getTopics() == null ^ this.getTopics() == null) return false; if (other.getTopics() != null && other.getTopics().equals(this.getTopics()) == false) return false; if (other.getQueues() == null ^ this.getQueues() == null) return false; if (other.getQueues() != null && other.getQueues().equals(this.getQueues()) == false) return false; if (other.getSourceAccessConfigurations() == null ^ this.getSourceAccessConfigurations() == null) return false; if (other.getSourceAccessConfigurations() != null && other.getSourceAccessConfigurations().equals(this.getSourceAccessConfigurations()) == false) return false; if (other.getSelfManagedEventSource() == null ^ this.getSelfManagedEventSource() == null) return false; if (other.getSelfManagedEventSource() != null && other.getSelfManagedEventSource().equals(this.getSelfManagedEventSource()) == false) return false; if (other.getFunctionResponseTypes() == null ^ this.getFunctionResponseTypes() == null) return false; if (other.getFunctionResponseTypes() != null && other.getFunctionResponseTypes().equals(this.getFunctionResponseTypes()) == false) return false; if (other.getAmazonManagedKafkaEventSourceConfig() == null ^ this.getAmazonManagedKafkaEventSourceConfig() == null) return false; if (other.getAmazonManagedKafkaEventSourceConfig() != null && other.getAmazonManagedKafkaEventSourceConfig().equals(this.getAmazonManagedKafkaEventSourceConfig()) == false) return false; if (other.getSelfManagedKafkaEventSourceConfig() == null ^ this.getSelfManagedKafkaEventSourceConfig() == null) return false; if (other.getSelfManagedKafkaEventSourceConfig() != null && other.getSelfManagedKafkaEventSourceConfig().equals(this.getSelfManagedKafkaEventSourceConfig()) == false) return false; if (other.getScalingConfig() == null ^ this.getScalingConfig() == null) return false; if (other.getScalingConfig() != null && other.getScalingConfig().equals(this.getScalingConfig()) == false) return false; if (other.getDocumentDBEventSourceConfig() == null ^ this.getDocumentDBEventSourceConfig() == null) return false; if (other.getDocumentDBEventSourceConfig() != null && other.getDocumentDBEventSourceConfig().equals(this.getDocumentDBEventSourceConfig()) == false) return false; return true; } @Override public int hashCode() { final int prime = 31; int hashCode = 1; hashCode = prime * hashCode + ((getEventSourceArn() == null) ? 0 : getEventSourceArn().hashCode()); hashCode = prime * hashCode + ((getFunctionName() == null) ? 0 : getFunctionName().hashCode()); hashCode = prime * hashCode + ((getEnabled() == null) ? 0 : getEnabled().hashCode()); hashCode = prime * hashCode + ((getBatchSize() == null) ? 0 : getBatchSize().hashCode()); hashCode = prime * hashCode + ((getFilterCriteria() == null) ? 0 : getFilterCriteria().hashCode()); hashCode = prime * hashCode + ((getMaximumBatchingWindowInSeconds() == null) ? 0 : getMaximumBatchingWindowInSeconds().hashCode()); hashCode = prime * hashCode + ((getParallelizationFactor() == null) ? 0 : getParallelizationFactor().hashCode()); hashCode = prime * hashCode + ((getStartingPosition() == null) ? 0 : getStartingPosition().hashCode()); hashCode = prime * hashCode + ((getStartingPositionTimestamp() == null) ? 0 : getStartingPositionTimestamp().hashCode()); hashCode = prime * hashCode + ((getDestinationConfig() == null) ? 0 : getDestinationConfig().hashCode()); hashCode = prime * hashCode + ((getMaximumRecordAgeInSeconds() == null) ? 0 : getMaximumRecordAgeInSeconds().hashCode()); hashCode = prime * hashCode + ((getBisectBatchOnFunctionError() == null) ? 0 : getBisectBatchOnFunctionError().hashCode()); hashCode = prime * hashCode + ((getMaximumRetryAttempts() == null) ? 0 : getMaximumRetryAttempts().hashCode()); hashCode = prime * hashCode + ((getTumblingWindowInSeconds() == null) ? 0 : getTumblingWindowInSeconds().hashCode()); hashCode = prime * hashCode + ((getTopics() == null) ? 0 : getTopics().hashCode()); hashCode = prime * hashCode + ((getQueues() == null) ? 0 : getQueues().hashCode()); hashCode = prime * hashCode + ((getSourceAccessConfigurations() == null) ? 0 : getSourceAccessConfigurations().hashCode()); hashCode = prime * hashCode + ((getSelfManagedEventSource() == null) ? 0 : getSelfManagedEventSource().hashCode()); hashCode = prime * hashCode + ((getFunctionResponseTypes() == null) ? 0 : getFunctionResponseTypes().hashCode()); hashCode = prime * hashCode + ((getAmazonManagedKafkaEventSourceConfig() == null) ? 0 : getAmazonManagedKafkaEventSourceConfig().hashCode()); hashCode = prime * hashCode + ((getSelfManagedKafkaEventSourceConfig() == null) ? 0 : getSelfManagedKafkaEventSourceConfig().hashCode()); hashCode = prime * hashCode + ((getScalingConfig() == null) ? 0 : getScalingConfig().hashCode()); hashCode = prime * hashCode + ((getDocumentDBEventSourceConfig() == null) ? 0 : getDocumentDBEventSourceConfig().hashCode()); return hashCode; } @Override public CreateEventSourceMappingRequest clone() { return (CreateEventSourceMappingRequest) super.clone(); } }