Class: AWSCDK::Lambda::EventSourceMappingOptions

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
lambda/event_source_mapping_options.rb

Direct Known Subclasses

EventSourceMappingProps

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(batch_size: nil, bisect_batch_on_error: nil, enabled: nil, event_source_arn: nil, filter_encryption: nil, filters: nil, kafka_bootstrap_servers: nil, kafka_consumer_group_id: nil, kafka_topic: nil, log_level: nil, max_batching_window: nil, max_concurrency: nil, max_record_age: nil, metrics_config: nil, on_failure: nil, parallelization_factor: nil, provisioned_poller_config: nil, report_batch_item_failures: nil, retry_attempts: nil, schema_registry_config: nil, source_access_configurations: nil, starting_position: nil, starting_position_timestamp: nil, support_s3_on_failure_destination: nil, tumbling_window: nil) ⇒ EventSourceMappingOptions

Returns a new instance of EventSourceMappingOptions.

Parameters:

  • batch_size (Numeric, nil) (defaults to: nil) —

    The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.

  • bisect_batch_on_error (Boolean, nil) (defaults to: nil) —

    If the function returns an error, split the batch in two and retry.

  • enabled (Boolean, nil) (defaults to: nil) —

    Set to false to disable the event source upon creation.

  • event_source_arn (String, nil) (defaults to: nil) —

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

  • filter_encryption (AWSCDK::KMS::IKey, nil) (defaults to: nil) —

    Add Customer managed KMS key to encrypt Filter Criteria.

  • filters (Array<Hash{String => Object}>, nil) (defaults to: nil) —

    Add filter criteria to Event Source.

  • kafka_bootstrap_servers (Array<String>, nil) (defaults to: nil) —

    A list of host and port pairs that are the addresses of the Kafka brokers in a self managed "bootstrap" Kafka cluster that a Kafka client connects to initially to bootstrap itself.

  • kafka_consumer_group_id (String, nil) (defaults to: nil) —

    The identifier for the Kafka consumer group to join.

  • kafka_topic (String, nil) (defaults to: nil) —

    The name of the Kafka topic.

  • log_level (AWSCDK::Lambda::EventSourceMappingLogLevel, nil) (defaults to: nil) —

    Configuration for logging verbosity from the event source mapping poller.

  • max_batching_window (AWSCDK::Duration, nil) (defaults to: nil) —

    The maximum amount of time to gather records before invoking the function.

  • max_concurrency (Numeric, nil) (defaults to: nil) —

    The maximum concurrency setting limits the number of concurrent instances of the function that an Amazon SQS event source can invoke.

  • max_record_age (AWSCDK::Duration, nil) (defaults to: nil) —

    The maximum age of a record that Lambda sends to a function for processing.

  • metrics_config (AWSCDK::Lambda::MetricsConfig, nil) (defaults to: nil) —

    Configuration for enhanced monitoring metrics collection When specified, enables collection of additional metrics for the stream event source.

  • on_failure (AWSCDK::Lambda::IEventSourceDlq, nil) (defaults to: nil) —

    An Amazon S3, Amazon SQS queue or Amazon SNS topic destination for discarded records.

  • parallelization_factor (Numeric, nil) (defaults to: nil) —

    The number of batches to process from each shard concurrently.

  • provisioned_poller_config (AWSCDK::Lambda::ProvisionedPollerConfig, nil) (defaults to: nil) —

    Configuration for provisioned pollers that read from the event source.

  • report_batch_item_failures (Boolean, nil) (defaults to: nil) —

    Allow functions to return partially successful responses for a batch of records.

  • retry_attempts (Numeric, nil) (defaults to: nil) —

    The maximum number of times to retry when the function returns an error.

  • schema_registry_config (AWSCDK::Lambda::ISchemaRegistry, nil) (defaults to: nil) —

    Specific configuration settings for a Kafka schema registry.

  • source_access_configurations (Array<AWSCDK::Lambda::SourceAccessConfiguration>, nil) (defaults to: nil) —

    Specific settings like the authentication protocol or the VPC components to secure access to your event source.

  • starting_position (AWSCDK::Lambda::StartingPosition, nil) (defaults to: nil) —

    The position in the DynamoDB, Kinesis or MSK stream where AWS Lambda should start reading.

  • starting_position_timestamp (Numeric, nil) (defaults to: nil) —

    The time from which to start reading, in Unix time seconds.

  • support_s3_on_failure_destination (Boolean, nil) (defaults to: nil) —

    Check if support S3 onfailure destination(OFD).

  • tumbling_window (AWSCDK::Duration, nil) (defaults to: nil) —

    The size of the tumbling windows to group records sent to DynamoDB or Kinesis.



31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
 
# File 'lambda/event_source_mapping_options.rb', line 31

def initialize(batch_size: nil, bisect_batch_on_error: nil, enabled: nil, event_source_arn: nil, filter_encryption: nil, filters: nil, kafka_bootstrap_servers: nil, kafka_consumer_group_id: nil, kafka_topic: nil, log_level: nil, max_batching_window: nil, max_concurrency: nil, max_record_age: nil, metrics_config: nil, on_failure: nil, parallelization_factor: nil, provisioned_poller_config: nil, report_batch_item_failures: nil, retry_attempts: nil, schema_registry_config: nil, source_access_configurations: nil, starting_position: nil, starting_position_timestamp: nil, support_s3_on_failure_destination: nil, tumbling_window: nil)
  @batch_size = batch_size
  Jsii::Type.check_type(@batch_size, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "batchSize") unless @batch_size.nil?
  @bisect_batch_on_error = bisect_batch_on_error
  Jsii::Type.check_type(@bisect_batch_on_error, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJib29sZWFuIn0=")), "bisectBatchOnError") unless @bisect_batch_on_error.nil?
  @enabled = enabled
  Jsii::Type.check_type(@enabled, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJib29sZWFuIn0=")), "enabled") unless @enabled.nil?
  @event_source_arn = event_source_arn
  Jsii::Type.check_type(@event_source_arn, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "eventSourceArn") unless @event_source_arn.nil?
  @filter_encryption = filter_encryption
  Jsii::Type.check_type(@filter_encryption, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfa21zLklLZXkifQ==")), "filterEncryption") unless @filter_encryption.nil?
  @filters = filters
  Jsii::Type.check_type(@filters, JSON.parse(Base64.strict_decode64("eyJjb2xsZWN0aW9uIjp7ImVsZW1lbnR0eXBlIjp7ImNvbGxlY3Rpb24iOnsiZWxlbWVudHR5cGUiOnsicHJpbWl0aXZlIjoiYW55In0sImtpbmQiOiJtYXAifX0sImtpbmQiOiJhcnJheSJ9fQ==")), "filters") unless @filters.nil?
  @kafka_bootstrap_servers = kafka_bootstrap_servers
  Jsii::Type.check_type(@kafka_bootstrap_servers, JSON.parse(Base64.strict_decode64("eyJjb2xsZWN0aW9uIjp7ImVsZW1lbnR0eXBlIjp7InByaW1pdGl2ZSI6InN0cmluZyJ9LCJraW5kIjoiYXJyYXkifX0=")), "kafkaBootstrapServers") unless @kafka_bootstrap_servers.nil?
  @kafka_consumer_group_id = kafka_consumer_group_id
  Jsii::Type.check_type(@kafka_consumer_group_id, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "kafkaConsumerGroupId") unless @kafka_consumer_group_id.nil?
  @kafka_topic = kafka_topic
  Jsii::Type.check_type(@kafka_topic, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "kafkaTopic") unless @kafka_topic.nil?
  @log_level = log_level
  Jsii::Type.check_type(@log_level, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLkV2ZW50U291cmNlTWFwcGluZ0xvZ0xldmVsIn0=")), "logLevel") unless @log_level.nil?
  @max_batching_window = max_batching_window
  Jsii::Type.check_type(@max_batching_window, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5EdXJhdGlvbiJ9")), "maxBatchingWindow") unless @max_batching_window.nil?
  @max_concurrency = max_concurrency
  Jsii::Type.check_type(@max_concurrency, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "maxConcurrency") unless @max_concurrency.nil?
  @max_record_age = max_record_age
  Jsii::Type.check_type(@max_record_age, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5EdXJhdGlvbiJ9")), "maxRecordAge") unless @max_record_age.nil?
  @metrics_config = metrics_config.is_a?(Hash) ? ::AWSCDK::Lambda::MetricsConfig.new(**metrics_config.transform_keys(&:to_sym)) : metrics_config
  Jsii::Type.check_type(@metrics_config, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLk1ldHJpY3NDb25maWcifQ==")), "metricsConfig") unless @metrics_config.nil?
  @on_failure = on_failure
  Jsii::Type.check_type(@on_failure, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLklFdmVudFNvdXJjZURscSJ9")), "onFailure") unless @on_failure.nil?
  @parallelization_factor = parallelization_factor
  Jsii::Type.check_type(@parallelization_factor, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "parallelizationFactor") unless @parallelization_factor.nil?
  @provisioned_poller_config = provisioned_poller_config.is_a?(Hash) ? ::AWSCDK::Lambda::ProvisionedPollerConfig.new(**provisioned_poller_config.transform_keys(&:to_sym)) : provisioned_poller_config
  Jsii::Type.check_type(@provisioned_poller_config, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLlByb3Zpc2lvbmVkUG9sbGVyQ29uZmlnIn0=")), "provisionedPollerConfig") unless @provisioned_poller_config.nil?
  @report_batch_item_failures = report_batch_item_failures
  Jsii::Type.check_type(@report_batch_item_failures, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJib29sZWFuIn0=")), "reportBatchItemFailures") unless @report_batch_item_failures.nil?
  @retry_attempts = retry_attempts
  Jsii::Type.check_type(@retry_attempts, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "retryAttempts") unless @retry_attempts.nil?
  @schema_registry_config = schema_registry_config
  Jsii::Type.check_type(@schema_registry_config, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLklTY2hlbWFSZWdpc3RyeSJ9")), "schemaRegistryConfig") unless @schema_registry_config.nil?
  @source_access_configurations = source_access_configurations.is_a?(Array) ? source_access_configurations.map { |jsii_v0| jsii_v0.is_a?(Hash) ? ::AWSCDK::Lambda::SourceAccessConfiguration.new(**jsii_v0.transform_keys(&:to_sym)) : jsii_v0 } : source_access_configurations
  Jsii::Type.check_type(@source_access_configurations, JSON.parse(Base64.strict_decode64("eyJjb2xsZWN0aW9uIjp7ImVsZW1lbnR0eXBlIjp7ImZxbiI6ImF3cy1jZGstbGliLmF3c19sYW1iZGEuU291cmNlQWNjZXNzQ29uZmlndXJhdGlvbiJ9LCJraW5kIjoiYXJyYXkifX0=")), "sourceAccessConfigurations") unless @source_access_configurations.nil?
  @starting_position = starting_position
  Jsii::Type.check_type(@starting_position, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLlN0YXJ0aW5nUG9zaXRpb24ifQ==")), "startingPosition") unless @starting_position.nil?
  @starting_position_timestamp = starting_position_timestamp
  Jsii::Type.check_type(@starting_position_timestamp, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "startingPositionTimestamp") unless @starting_position_timestamp.nil?
  @support_s3_on_failure_destination = support_s3_on_failure_destination
  Jsii::Type.check_type(@support_s3_on_failure_destination, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJib29sZWFuIn0=")), "supportS3OnFailureDestination") unless @support_s3_on_failure_destination.nil?
  @tumbling_window = tumbling_window
  Jsii::Type.check_type(@tumbling_window, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5EdXJhdGlvbiJ9")), "tumblingWindow") unless @tumbling_window.nil?
end

Instance Attribute Details

#batch_size ⇒ Numeric? (readonly)

Note:

Default: - Amazon Kinesis, Amazon DynamoDB, and Amazon MSK is 100 records. The default for Amazon SQS is 10 messages. For standard SQS queues, the maximum is 10,000. For FIFO SQS queues, the maximum is 10.

The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.

Your function receives an event with all the retrieved records.

Valid Range: Minimum value of 1. Maximum value of 10000.

Returns:

  • (Numeric, nil) 


93
94
95
 
# File 'lambda/event_source_mapping_options.rb', line 93

def batch_size
  @batch_size
end

#bisect_batch_on_error ⇒ Boolean? (readonly)

Note:

Default: false

If the function returns an error, split the batch in two and retry.

Returns:

  • (Boolean, nil) 


98
99
100
 
# File 'lambda/event_source_mapping_options.rb', line 98

def bisect_batch_on_error
  @bisect_batch_on_error
end

#enabled ⇒ Boolean? (readonly)

Note:

Default: true

Set to false to disable the event source upon creation.

Returns:

  • (Boolean, nil) 


103
104
105
 
# File 'lambda/event_source_mapping_options.rb', line 103

def enabled
  @enabled
end

#event_source_arn ⇒ String? (readonly)

Note:

Default: - not set if using a self managed Kafka cluster, throws an error otherwise

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

Any record added to this stream can invoke the Lambda function.

Returns:

  • (String, nil) 


111
112
113
 
# File 'lambda/event_source_mapping_options.rb', line 111

def event_source_arn
  @event_source_arn
end

#filter_encryption ⇒ AWSCDK::KMS::IKey? (readonly)

Note:

Default: - none

Add Customer managed KMS key to encrypt Filter Criteria.

Returns:

See Also:



117
118
119
 
# File 'lambda/event_source_mapping_options.rb', line 117

def filter_encryption
  @filter_encryption
end

#filters ⇒ Array<Hash{String => Object}>? (readonly)

Note:

Default: - none

Add filter criteria to Event Source.

Returns:

  • (Array<Hash{String => Object}>, nil)

See Also:



123
124
125
 
# File 'lambda/event_source_mapping_options.rb', line 123

def filters
  @filters
end

#kafka_bootstrap_servers ⇒ Array<String>? (readonly)

Note:

Default: - none

A list of host and port pairs that are the addresses of the Kafka brokers in a self managed "bootstrap" Kafka cluster that a Kafka client connects to initially to bootstrap itself.

They are in the format abc.example.com:9096.

Returns:

  • (Array<String>, nil) 


130
131
132
 
# File 'lambda/event_source_mapping_options.rb', line 130

def kafka_bootstrap_servers
  @kafka_bootstrap_servers
end

#kafka_consumer_group_id ⇒ String? (readonly)

Note:

Default: - none

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. The value must have a length between 1 and 200 and full the pattern '[a-zA-Z0-9-/:_+=.@-]'. For more information, see Customizable consumer group ID.

Returns:

  • (String, nil)

See Also:



138
139
140
 
# File 'lambda/event_source_mapping_options.rb', line 138

def kafka_consumer_group_id
  @kafka_consumer_group_id
end

#kafka_topic ⇒ String? (readonly)

Note:

Default: - no topic

The name of the Kafka topic.

Returns:

  • (String, nil) 


143
144
145
 
# File 'lambda/event_source_mapping_options.rb', line 143

def kafka_topic
  @kafka_topic
end

#log_level ⇒ AWSCDK::Lambda::EventSourceMappingLogLevel? (readonly)

Note:

Default: - No logging

Configuration for logging verbosity from the event source mapping poller.

This configuration controls the verbosity of the logs generated by the polling infrastructure that reads events from the event source. The logs provide insights into the internal operations of the event source mapping, including connection status, polling behavior, and error conditions.

Returns:



152
153
154
 
# File 'lambda/event_source_mapping_options.rb', line 152

def log_level
  @log_level
end

#max_batching_window ⇒ AWSCDK::Duration? (readonly)

Note:

Default: Duration.seconds(0)

The maximum amount of time to gather records before invoking the function.

Maximum of Duration.minutes(5)

Returns:



159
160
161
 
# File 'lambda/event_source_mapping_options.rb', line 159

def max_batching_window
  @max_batching_window
end

#max_concurrency ⇒ Numeric? (readonly)

Note:

Default: - No specific limit.

The maximum concurrency setting limits the number of concurrent instances of the function that an Amazon SQS event source can invoke.

Returns:

  • (Numeric, nil)

See Also:



165
166
167
 
# File 'lambda/event_source_mapping_options.rb', line 165

def max_concurrency
  @max_concurrency
end

#max_record_age ⇒ AWSCDK::Duration? (readonly)

Note:

Default: - infinite or until the record expires.

The maximum age of a record that Lambda sends to a function for processing.

Valid Range:

  • Minimum value of 60 seconds
  • Maximum value of 7 days

Returns:



175
176
177
 
# File 'lambda/event_source_mapping_options.rb', line 175

def max_record_age
  @max_record_age
end

#metrics_config ⇒ AWSCDK::Lambda::MetricsConfig? (readonly)

Note:

Default: - Enhanced monitoring is disabled

Configuration for enhanced monitoring metrics collection When specified, enables collection of additional metrics for the stream event source.

Returns:



180
181
182
 
# File 'lambda/event_source_mapping_options.rb', line 180

def metrics_config
  @metrics_config
end

#on_failure ⇒ AWSCDK::Lambda::IEventSourceDlq? (readonly)

Note:

Default: discarded records are ignored

An Amazon S3, Amazon SQS queue or Amazon SNS topic destination for discarded records.

Returns:



185
186
187
 
# File 'lambda/event_source_mapping_options.rb', line 185

def on_failure
  @on_failure
end

#parallelization_factor ⇒ Numeric? (readonly)

Note:

Default: 1

The number of batches to process from each shard concurrently.

Valid Range:

  • Minimum value of 1
  • Maximum value of 10

Returns:

  • (Numeric, nil) 


195
196
197
 
# File 'lambda/event_source_mapping_options.rb', line 195

def parallelization_factor
  @parallelization_factor
end

#provisioned_poller_config ⇒ AWSCDK::Lambda::ProvisionedPollerConfig? (readonly)

Note:

Default: - no provisioned pollers

Configuration for provisioned pollers that read from the event source.

When specified, allows control over the minimum and maximum number of pollers that can be provisioned to process events from the source.

Returns:



203
204
205
 
# File 'lambda/event_source_mapping_options.rb', line 203

def provisioned_poller_config
  @provisioned_poller_config
end

#report_batch_item_failures ⇒ Boolean? (readonly)

Note:

Default: false

Allow functions to return partially successful responses for a batch of records.

Returns:

  • (Boolean, nil)

See Also:



209
210
211
 
# File 'lambda/event_source_mapping_options.rb', line 209

def report_batch_item_failures
  @report_batch_item_failures
end

#retry_attempts ⇒ Numeric? (readonly)

Note:

Default: - infinite or until the record expires.

The maximum number of times to retry when the function returns an error.

Set to undefined if you want lambda to keep retrying infinitely or until the record expires.

Valid Range:

  • Minimum value of 0
  • Maximum value of 10000

Returns:

  • (Numeric, nil) 


222
223
224
 
# File 'lambda/event_source_mapping_options.rb', line 222

def retry_attempts
  @retry_attempts
end

#schema_registry_config ⇒ AWSCDK::Lambda::ISchemaRegistry? (readonly)

Note:

Default: - none

Specific configuration settings for a Kafka schema registry.

Returns:



227
228
229
 
# File 'lambda/event_source_mapping_options.rb', line 227

def schema_registry_config
  @schema_registry_config
end

#source_access_configurations ⇒ Array<AWSCDK::Lambda::SourceAccessConfiguration>? (readonly)

Note:

Default: - none

Specific settings like the authentication protocol or the VPC components to secure access to your event source.

Returns:

See Also:



233
234
235
 
# File 'lambda/event_source_mapping_options.rb', line 233

def source_access_configurations
  @source_access_configurations
end

#starting_position ⇒ AWSCDK::Lambda::StartingPosition? (readonly)

Note:

Default: - no starting position

The position in the DynamoDB, Kinesis or MSK stream where AWS Lambda should start reading.

Returns:

See Also:



239
240
241
 
# File 'lambda/event_source_mapping_options.rb', line 239

def starting_position
  @starting_position
end

#starting_position_timestamp ⇒ Numeric? (readonly)

Note:

Default: - no timestamp

The time from which to start reading, in Unix time seconds.

Returns:

  • (Numeric, nil) 


244
245
246
 
# File 'lambda/event_source_mapping_options.rb', line 244

def starting_position_timestamp
  @starting_position_timestamp
end

#support_s3_on_failure_destination ⇒ Boolean? (readonly)

Note:

Default: false

Check if support S3 onfailure destination(OFD).

Kinesis, DynamoDB, MSK and self managed kafka event support S3 OFD

Returns:

  • (Boolean, nil) 


251
252
253
 
# File 'lambda/event_source_mapping_options.rb', line 251

def support_s3_on_failure_destination
  @support_s3_on_failure_destination
end

#tumbling_window ⇒ AWSCDK::Duration? (readonly)

Note:

Default: - None

The size of the tumbling windows to group records sent to DynamoDB or Kinesis.

Returns:

See Also:



257
258
259
 
# File 'lambda/event_source_mapping_options.rb', line 257

def tumbling_window
  @tumbling_window
end

Class Method Details

.jsii_properties ⇒ Object 



259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
 
# File 'lambda/event_source_mapping_options.rb', line 259

def self.jsii_properties
  {
    :batch_size => "batchSize",
    :bisect_batch_on_error => "bisectBatchOnError",
    :enabled => "enabled",
    :event_source_arn => "eventSourceArn",
    :filter_encryption => "filterEncryption",
    :filters => "filters",
    :kafka_bootstrap_servers => "kafkaBootstrapServers",
    :kafka_consumer_group_id => "kafkaConsumerGroupId",
    :kafka_topic => "kafkaTopic",
    :log_level => "logLevel",
    :max_batching_window => "maxBatchingWindow",
    :max_concurrency => "maxConcurrency",
    :max_record_age => "maxRecordAge",
    :metrics_config => "metricsConfig",
    :on_failure => "onFailure",
    :parallelization_factor => "parallelizationFactor",
    :provisioned_poller_config => "provisionedPollerConfig",
    :report_batch_item_failures => "reportBatchItemFailures",
    :retry_attempts => "retryAttempts",
    :schema_registry_config => "schemaRegistryConfig",
    :source_access_configurations => "sourceAccessConfigurations",
    :starting_position => "startingPosition",
    :starting_position_timestamp => "startingPositionTimestamp",
    :support_s3_on_failure_destination => "supportS3OnFailureDestination",
    :tumbling_window => "tumblingWindow",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
 
# File 'lambda/event_source_mapping_options.rb', line 289

def to_jsii
  result = {}
  result.merge!({
    "batchSize" => @batch_size,
    "bisectBatchOnError" => @bisect_batch_on_error,
    "enabled" => @enabled,
    "eventSourceArn" => @event_source_arn,
    "filterEncryption" => @filter_encryption,
    "filters" => @filters,
    "kafkaBootstrapServers" => @kafka_bootstrap_servers,
    "kafkaConsumerGroupId" => @kafka_consumer_group_id,
    "kafkaTopic" => @kafka_topic,
    "logLevel" => @log_level,
    "maxBatchingWindow" => @max_batching_window,
    "maxConcurrency" => @max_concurrency,
    "maxRecordAge" => @max_record_age,
    "metricsConfig" => @metrics_config,
    "onFailure" => @on_failure,
    "parallelizationFactor" => @parallelization_factor,
    "provisionedPollerConfig" => @provisioned_poller_config,
    "reportBatchItemFailures" => @report_batch_item_failures,
    "retryAttempts" => @retry_attempts,
    "schemaRegistryConfig" => @schema_registry_config,
    "sourceAccessConfigurations" => @source_access_configurations,
    "startingPosition" => @starting_position,
    "startingPositionTimestamp" => @starting_position_timestamp,
    "supportS3OnFailureDestination" => @support_s3_on_failure_destination,
    "tumblingWindow" => @tumbling_window,
  })
  result.compact
end