Class: AWSCDK::LambdaEventSources::SelfManagedKafkaEventSourceProps

Inherits:
KafkaEventSourceProps
  • Object
show all
Defined in:
lambda_event_sources/self_managed_kafka_event_source_props.rb

Overview

Properties for a self managed Kafka cluster event source.

If your Kafka cluster is only reachable via VPC make sure to configure it.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(starting_position:, batch_size: nil, enabled: nil, max_batching_window: nil, provisioned_poller_config: nil, topic:, bisect_batch_on_error: nil, consumer_group_id: nil, filter_encryption: nil, filters: nil, log_level: nil, max_record_age: nil, metrics_config: nil, on_failure: nil, report_batch_item_failures: nil, retry_attempts: nil, schema_registry_config: nil, secret: nil, starting_position_timestamp: nil, bootstrap_servers:, authentication_method: nil, root_ca_certificate: nil, security_group: nil, vpc: nil, vpc_subnets: nil) ⇒ SelfManagedKafkaEventSourceProps

Returns a new instance of SelfManagedKafkaEventSourceProps.

Parameters:

  • starting_position (AWSCDK::Lambda::StartingPosition) —

    Where to begin consuming the stream.

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

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

    If the stream event source mapping should be enabled.

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

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

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

    Configuration for provisioned pollers that read from the event source.

  • topic (String) —

    The Kafka topic to subscribe to.

  • bisect_batch_on_error (Boolean, nil) (defaults to: nil) —
    • If the function returns an error, split the batch in two and retry.
  • consumer_group_id (String, nil) (defaults to: nil) —

    The identifier for the Kafka consumer group to join.

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

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

    Configuration for logging verbosity from the event source mapping poller.

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

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

    Add an on Failure Destination for this Kafka event.

  • 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) —
    • Maximum number of retry attempts.
  • schema_registry_config (AWSCDK::Lambda::ISchemaRegistry, nil) (defaults to: nil) —

    Specific configuration settings for a Kafka schema registry.

  • secret (AWSCDK::SecretsManager::ISecret, nil) (defaults to: nil) —

    The secret with the Kafka credentials, see https://docs.aws.amazon.com/msk/latest/developerguide/msk-password.html for details This field is required if your Kafka brokers are accessed over the Internet.

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

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

  • bootstrap_servers (Array<String>) —

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

  • authentication_method (AWSCDK::LambdaEventSources::AuthenticationMethod, nil) (defaults to: nil) —

    The authentication method for your Kafka cluster.

  • root_ca_certificate (AWSCDK::SecretsManager::ISecret, nil) (defaults to: nil) —

    The secret with the root CA certificate used by your Kafka brokers for TLS encryption This field is required if your Kafka brokers use certificates signed by a private CA.

  • security_group (AWSCDK::EC2::ISecurityGroup, nil) (defaults to: nil) —

    If your Kafka brokers are only reachable via VPC, provide the security group here.

  • vpc (AWSCDK::EC2::IVPC, nil) (defaults to: nil) —

    If your Kafka brokers are only reachable via VPC provide the VPC here.

  • vpc_subnets (AWSCDK::EC2::SubnetSelection, nil) (defaults to: nil) —

    If your Kafka brokers are only reachable via VPC, provide the subnets selection here.



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
83
84
85
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 34

def initialize(starting_position:, batch_size: nil, enabled: nil, max_batching_window: nil, provisioned_poller_config: nil, topic:, bisect_batch_on_error: nil, consumer_group_id: nil, filter_encryption: nil, filters: nil, log_level: nil, max_record_age: nil, metrics_config: nil, on_failure: nil, report_batch_item_failures: nil, retry_attempts: nil, schema_registry_config: nil, secret: nil, starting_position_timestamp: nil, bootstrap_servers:, authentication_method: nil, root_ca_certificate: nil, security_group: nil, vpc: nil, vpc_subnets: nil)
  @starting_position = starting_position
  Jsii::Type.check_type(@starting_position, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLlN0YXJ0aW5nUG9zaXRpb24ifQ==")), "startingPosition")
  @batch_size = batch_size
  Jsii::Type.check_type(@batch_size, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "batchSize") unless @batch_size.nil?
  @enabled = enabled
  Jsii::Type.check_type(@enabled, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJib29sZWFuIn0=")), "enabled") unless @enabled.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?
  @provisioned_poller_config = provisioned_poller_config.is_a?(Hash) ? ::AWSCDK::LambdaEventSources::ProvisionedPollerConfig.new(**provisioned_poller_config.transform_keys(&:to_sym)) : provisioned_poller_config
  Jsii::Type.check_type(@provisioned_poller_config, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhX2V2ZW50X3NvdXJjZXMuUHJvdmlzaW9uZWRQb2xsZXJDb25maWcifQ==")), "provisionedPollerConfig") unless @provisioned_poller_config.nil?
  @topic = topic
  Jsii::Type.check_type(@topic, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "topic")
  @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?
  @consumer_group_id = consumer_group_id
  Jsii::Type.check_type(@consumer_group_id, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "consumerGroupId") unless @consumer_group_id.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?
  @log_level = log_level
  Jsii::Type.check_type(@log_level, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLkV2ZW50U291cmNlTWFwcGluZ0xvZ0xldmVsIn0=")), "logLevel") unless @log_level.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?
  @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?
  @secret = secret
  Jsii::Type.check_type(@secret, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc2VjcmV0c21hbmFnZXIuSVNlY3JldCJ9")), "secret") unless @secret.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?
  @bootstrap_servers = bootstrap_servers
  Jsii::Type.check_type(@bootstrap_servers, JSON.parse(Base64.strict_decode64("eyJjb2xsZWN0aW9uIjp7ImVsZW1lbnR0eXBlIjp7InByaW1pdGl2ZSI6InN0cmluZyJ9LCJraW5kIjoiYXJyYXkifX0=")), "bootstrapServers")
  @authentication_method = authentication_method
  Jsii::Type.check_type(@authentication_method, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhX2V2ZW50X3NvdXJjZXMuQXV0aGVudGljYXRpb25NZXRob2QifQ==")), "authenticationMethod") unless @authentication_method.nil?
  @root_ca_certificate = root_ca_certificate
  Jsii::Type.check_type(@root_ca_certificate, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc2VjcmV0c21hbmFnZXIuSVNlY3JldCJ9")), "rootCACertificate") unless @root_ca_certificate.nil?
  @security_group = security_group
  Jsii::Type.check_type(@security_group, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfZWMyLklTZWN1cml0eUdyb3VwIn0=")), "securityGroup") unless @security_group.nil?
  @vpc = vpc
  Jsii::Type.check_type(@vpc, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfZWMyLklWcGMifQ==")), "vpc") unless @vpc.nil?
  @vpc_subnets = vpc_subnets.is_a?(Hash) ? ::AWSCDK::EC2::SubnetSelection.new(**vpc_subnets.transform_keys(&:to_sym)) : vpc_subnets
  Jsii::Type.check_type(@vpc_subnets, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfZWMyLlN1Ym5ldFNlbGVjdGlvbiJ9")), "vpcSubnets") unless @vpc_subnets.nil?
end

Instance Attribute Details

#authentication_method ⇒ AWSCDK::LambdaEventSources::AuthenticationMethod? (readonly)

Note:

Default: AuthenticationMethod.SASL_SCRAM_512_AUTH

The authentication method for your Kafka cluster.

Returns:



226
227
228
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 226

def authentication_method
  @authentication_method
end

#batch_size ⇒ Numeric? (readonly)

Note:

Default: 100

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:

    • 1000 for DynamoEventSource
    • 10000 for KinesisEventSource, ManagedKafkaEventSource and SelfManagedKafkaEventSource

Returns:

  • (Numeric, nil) 


106
107
108
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 106

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) 


137
138
139
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 137

def bisect_batch_on_error
  @bisect_batch_on_error
end

#bootstrap_servers ⇒ Array<String> (readonly)

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

They are in the format abc.xyz.com:xxxx.

Returns:

  • (Array<String>) 


221
222
223
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 221

def bootstrap_servers
  @bootstrap_servers
end

#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-/:_+=.@-]'.

Returns:

  • (String, nil)

See Also:



145
146
147
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 145

def consumer_group_id
  @consumer_group_id
end

#enabled ⇒ Boolean? (readonly)

Note:

Default: true

If the stream event source mapping should be enabled.

Returns:

  • (Boolean, nil) 


111
112
113
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 111

def enabled
  @enabled
end

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

Note:

Default: - none

Add Customer managed KMS key to encrypt Filter Criteria.

Returns:

See Also:



151
152
153
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 151

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:



157
158
159
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 157

def filters
  @filters
end

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

Note:

Default: - No logging

Configuration for logging verbosity from the event source mapping poller.

Returns:



162
163
164
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 162

def log_level
  @log_level
end

#max_batching_window ⇒ AWSCDK::Duration? (readonly)

Note:

Default: - Duration.seconds(0) for Kinesis, DynamoDB, and SQS event sources, Duration.millis(500) for MSK, self-managed Kafka, and Amazon MQ.

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

Maximum of Duration.minutes(5).

Returns:

See Also:



119
120
121
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 119

def max_batching_window
  @max_batching_window
end

#max_record_age ⇒ AWSCDK::Duration? (readonly)

Note:

Default: -1

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

The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, Lambda never discards old records. Record are valid until it expires in the event source.

Returns:



171
172
173
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 171

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.

Returns:



176
177
178
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 176

def metrics_config
  @metrics_config
end

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

Note:

Default: - discarded records are ignored

Add an on Failure Destination for this Kafka event.

Supported destinations:

  • {@link KafkaDlq } - Send failed records to a Kafka topic
  • SNS topics - Send failed records to an SNS topic
  • SQS queues - Send failed records to an SQS queue
  • S3 buckets - Send failed records to an S3 bucket

Returns:



188
189
190
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 188

def on_failure
  @on_failure
end

#provisioned_poller_config ⇒ AWSCDK::LambdaEventSources::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:

See Also:



128
129
130
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 128

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) 


193
194
195
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 193

def report_batch_item_failures
  @report_batch_item_failures
end

#retry_attempts ⇒ Numeric? (readonly)

Note:

Default: -1 (infinite retries)

  • Maximum number of retry attempts.

Set to -1 for infinite retries (until the record expires in the event source).

Returns:

  • (Numeric, nil) 


200
201
202
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 200

def retry_attempts
  @retry_attempts
end

#root_ca_certificate ⇒ AWSCDK::SecretsManager::ISecret? (readonly)

Note:

Default: - none

The secret with the root CA certificate used by your Kafka brokers for TLS encryption This field is required if your Kafka brokers use certificates signed by a private CA.

Returns:



231
232
233
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 231

def root_ca_certificate
  @root_ca_certificate
end

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

Note:

Default: - none

Specific configuration settings for a Kafka schema registry.

Returns:



205
206
207
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 205

def schema_registry_config
  @schema_registry_config
end

#secret ⇒ AWSCDK::SecretsManager::ISecret? (readonly)

Note:

Default: none

The secret with the Kafka credentials, see https://docs.aws.amazon.com/msk/latest/developerguide/msk-password.html for details This field is required if your Kafka brokers are accessed over the Internet.

Returns:



210
211
212
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 210

def secret
  @secret
end

#security_group ⇒ AWSCDK::EC2::ISecurityGroup? (readonly)

Note:

Default: - none, required if setting vpc

If your Kafka brokers are only reachable via VPC, provide the security group here.

Returns:



236
237
238
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 236

def security_group
  @security_group
end

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

Where to begin consuming the stream.

Returns:



90
91
92
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 90

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) 


215
216
217
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 215

def starting_position_timestamp
  @starting_position_timestamp
end

#topic ⇒ String (readonly)

The Kafka topic to subscribe to.

Returns:

  • (String) 


132
133
134
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 132

def topic
  @topic
end

#vpc ⇒ AWSCDK::EC2::IVPC? (readonly)

Note:

Default: none

If your Kafka brokers are only reachable via VPC provide the VPC here.

Returns:



241
242
243
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 241

def vpc
  @vpc
end

#vpc_subnets ⇒ AWSCDK::EC2::SubnetSelection? (readonly)

Note:

Default: - none, required if setting vpc

If your Kafka brokers are only reachable via VPC, provide the subnets selection here.

Returns:



246
247
248
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 246

def vpc_subnets
  @vpc_subnets
end

Class Method Details

.jsii_properties ⇒ Object 



248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 248

def self.jsii_properties
  {
    :starting_position => "startingPosition",
    :batch_size => "batchSize",
    :enabled => "enabled",
    :max_batching_window => "maxBatchingWindow",
    :provisioned_poller_config => "provisionedPollerConfig",
    :topic => "topic",
    :bisect_batch_on_error => "bisectBatchOnError",
    :consumer_group_id => "consumerGroupId",
    :filter_encryption => "filterEncryption",
    :filters => "filters",
    :log_level => "logLevel",
    :max_record_age => "maxRecordAge",
    :metrics_config => "metricsConfig",
    :on_failure => "onFailure",
    :report_batch_item_failures => "reportBatchItemFailures",
    :retry_attempts => "retryAttempts",
    :schema_registry_config => "schemaRegistryConfig",
    :secret => "secret",
    :starting_position_timestamp => "startingPositionTimestamp",
    :bootstrap_servers => "bootstrapServers",
    :authentication_method => "authenticationMethod",
    :root_ca_certificate => "rootCACertificate",
    :security_group => "securityGroup",
    :vpc => "vpc",
    :vpc_subnets => "vpcSubnets",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
 
# File 'lambda_event_sources/self_managed_kafka_event_source_props.rb', line 278

def to_jsii
  result = {}
  result.merge!(super)
  result.merge!({
    "startingPosition" => @starting_position,
    "batchSize" => @batch_size,
    "enabled" => @enabled,
    "maxBatchingWindow" => @max_batching_window,
    "provisionedPollerConfig" => @provisioned_poller_config,
    "topic" => @topic,
    "bisectBatchOnError" => @bisect_batch_on_error,
    "consumerGroupId" => @consumer_group_id,
    "filterEncryption" => @filter_encryption,
    "filters" => @filters,
    "logLevel" => @log_level,
    "maxRecordAge" => @max_record_age,
    "metricsConfig" => @metrics_config,
    "onFailure" => @on_failure,
    "reportBatchItemFailures" => @report_batch_item_failures,
    "retryAttempts" => @retry_attempts,
    "schemaRegistryConfig" => @schema_registry_config,
    "secret" => @secret,
    "startingPositionTimestamp" => @starting_position_timestamp,
    "bootstrapServers" => @bootstrap_servers,
    "authenticationMethod" => @authentication_method,
    "rootCACertificate" => @root_ca_certificate,
    "securityGroup" => @security_group,
    "vpc" => @vpc,
    "vpcSubnets" => @vpc_subnets,
  })
  result.compact
end