Class: AWSCDK::Lambda::CfnEventSourceMapping::SchemaRegistryConfigProperty

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

Overview

Specific configuration settings for a Kafka schema registry.

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(access_configs: nil, event_record_format: nil, schema_registry_uri: nil, schema_validation_configs: nil) ⇒ SchemaRegistryConfigProperty

Returns a new instance of SchemaRegistryConfigProperty.

Parameters:



1397
1398
1399
1400
1401
1402
1403
1404
1405
1406
 
# File 'lambda/cfn_event_source_mapping.rb', line 1397

def initialize(access_configs: nil, event_record_format: nil, schema_registry_uri: nil, schema_validation_configs: nil)
  @access_configs = access_configs
  Jsii::Type.check_type(@access_configs, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImNvbGxlY3Rpb24iOnsiZWxlbWVudHR5cGUiOnsidW5pb24iOnsidHlwZXMiOlt7ImZxbiI6ImF3cy1jZGstbGliLklSZXNvbHZhYmxlIn0seyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLkNmbkV2ZW50U291cmNlTWFwcGluZy5TY2hlbWFSZWdpc3RyeUFjY2Vzc0NvbmZpZ1Byb3BlcnR5In1dfX0sImtpbmQiOiJhcnJheSJ9fV19fQ==")), "accessConfigs") unless @access_configs.nil?
  @event_record_format = event_record_format
  Jsii::Type.check_type(@event_record_format, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "eventRecordFormat") unless @event_record_format.nil?
  @schema_registry_uri = schema_registry_uri
  Jsii::Type.check_type(@schema_registry_uri, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "schemaRegistryUri") unless @schema_registry_uri.nil?
  @schema_validation_configs = schema_validation_configs
  Jsii::Type.check_type(@schema_validation_configs, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImNvbGxlY3Rpb24iOnsiZWxlbWVudHR5cGUiOnsidW5pb24iOnsidHlwZXMiOlt7ImZxbiI6ImF3cy1jZGstbGliLklSZXNvbHZhYmxlIn0seyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLkNmbkV2ZW50U291cmNlTWFwcGluZy5TY2hlbWFWYWxpZGF0aW9uQ29uZmlnUHJvcGVydHkifV19fSwia2luZCI6ImFycmF5In19XX19")), "schemaValidationConfigs") unless @schema_validation_configs.nil?
end

Instance Attribute Details

#access_configs ⇒ AWSCDK::IResolvable, ... (readonly)

An array of access configuration objects that tell Lambda how to authenticate with your schema registry.

Returns:

See Also:



1412
1413
1414
 
# File 'lambda/cfn_event_source_mapping.rb', line 1412

def access_configs
  @access_configs
end

#event_record_format ⇒ String? (readonly)

The record format that Lambda delivers to your function after schema validation.

  • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.
  • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.

Returns:

  • (String, nil)

See Also:



1420
1421
1422
 
# File 'lambda/cfn_event_source_mapping.rb', line 1420

def event_record_format
  @event_record_format
end

#schema_registry_uri ⇒ String? (readonly)

The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

  • For AWS Glue schema registries, use the ARN of the registry.
  • For Confluent schema registries, use the URL of the registry.

Returns:

  • (String, nil)

See Also:



1428
1429
1430
 
# File 'lambda/cfn_event_source_mapping.rb', line 1428

def schema_registry_uri
  @schema_registry_uri
end

#schema_validation_configs ⇒ AWSCDK::IResolvable, ... (readonly)

An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.

Returns:

See Also:



1433
1434
1435
 
# File 'lambda/cfn_event_source_mapping.rb', line 1433

def schema_validation_configs
  @schema_validation_configs
end

Class Method Details

.jsii_properties ⇒ Object 



1435
1436
1437
1438
1439
1440
1441
1442
 
# File 'lambda/cfn_event_source_mapping.rb', line 1435

def self.jsii_properties
  {
    :access_configs => "accessConfigs",
    :event_record_format => "eventRecordFormat",
    :schema_registry_uri => "schemaRegistryUri",
    :schema_validation_configs => "schemaValidationConfigs",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



1444
1445
1446
1447
1448
1449
1450
1451
1452
1453
 
# File 'lambda/cfn_event_source_mapping.rb', line 1444

def to_jsii
  result = {}
  result.merge!({
    "accessConfigs" => @access_configs,
    "eventRecordFormat" => @event_record_format,
    "schemaRegistryUri" => @schema_registry_uri,
    "schemaValidationConfigs" => @schema_validation_configs,
  })
  result.compact
end