class Amazonite::Lambda::KafkaSchemaValidationConfig

Overview

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

Included Modules

Defined in:

lambda/kafka_schema_validation_config.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(pull : JSON::PullParser) #

[View source]
def self.new(attribute : KafkaSchemaValidationAttribute | Nil = nil) #

[View source]

Instance Method Detail

def ==(other : self) #
Description copied from class Reference

Returns true if this reference is the same as other. Invokes same?.


def attribute : KafkaSchemaValidationAttribute | Nil #

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.


[View source]
def attribute=(attribute : KafkaSchemaValidationAttribute | Nil) #

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.


[View source]
def hash(hasher) #
Description copied from class Reference

See Object#hash(hasher)


def validate! : Nil #

[View source]