Class: AWSCDK::Lambda::KafkaSchemaValidationConfig

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

Overview

Specific schema validation configuration settings that tell Lambda the message attributes you want to validate and filter using your schema registry.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(attribute:) ⇒ KafkaSchemaValidationConfig

Returns a new instance of KafkaSchemaValidationConfig.

Parameters:



8
9
10
11
# File 'lambda/kafka_schema_validation_config.rb', line 8

def initialize(attribute:)
  @attribute = attribute
  Jsii::Type.check_type(@attribute, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLkthZmthU2NoZW1hVmFsaWRhdGlvbkF0dHJpYnV0ZSJ9")), "attribute")
end

Instance Attribute Details

#attributeAWSCDK::Lambda::KafkaSchemaValidationAttribute (readonly)

The attributes you want your schema registry to validate and filter for.

If you selected JSON as the EventRecordFormat, Lambda also deserializes the selected message attributes.



18
19
20
# File 'lambda/kafka_schema_validation_config.rb', line 18

def attribute
  @attribute
end

Class Method Details

.jsii_propertiesObject



20
21
22
23
24
# File 'lambda/kafka_schema_validation_config.rb', line 20

def self.jsii_properties
  {
    :attribute => "attribute",
  }
end

Instance Method Details

#to_jsiiObject



26
27
28
29
30
31
32
# File 'lambda/kafka_schema_validation_config.rb', line 26

def to_jsii
  result = {}
  result.merge!({
    "attribute" => @attribute,
  })
  result.compact
end