class
Amazonite::Lambda::KafkaSchemaRegistryConfig
- Amazonite::Lambda::KafkaSchemaRegistryConfig
- Reference
- Object
Overview
Specific configuration settings for a Kafka schema registry.
Included Modules
- JSON::Serializable
Defined in:
lambda/kafka_schema_registry_config.crConstructors
- .new(pull : JSON::PullParser)
- .new(schema_registry_uri : String | Nil = nil, event_record_format : SchemaRegistryEventRecordFormat | Nil = nil, access_configs : Array(KafkaSchemaRegistryAccessConfig) | Nil = nil, schema_validation_configs : Array(KafkaSchemaValidationConfig) | Nil = nil)
- .new(*, __pull_for_json_serializable pull : JSON::PullParser)
Instance Method Summary
-
#==(other : self)
Returns
trueif this reference is the same as other. -
#access_configs : Array(KafkaSchemaRegistryAccessConfig) | Nil
An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
-
#access_configs=(access_configs : Array(KafkaSchemaRegistryAccessConfig) | Nil)
An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
-
#event_record_format : SchemaRegistryEventRecordFormat | Nil
The record format that Lambda delivers to your function after schema validation.
-
#event_record_format=(event_record_format : SchemaRegistryEventRecordFormat | Nil)
The record format that Lambda delivers to your function after schema validation.
-
#hash(hasher)
See
Object#hash(hasher) -
#schema_registry_uri : String | Nil
The URI for your schema registry.
-
#schema_registry_uri=(schema_registry_uri : String | Nil)
The URI for your schema registry.
-
#schema_validation_configs : Array(KafkaSchemaValidationConfig) | Nil
An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
-
#schema_validation_configs=(schema_validation_configs : Array(KafkaSchemaValidationConfig) | Nil)
An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
- #validate! : Nil
Constructor Detail
Instance Method Detail
Returns true if this reference is the same as other. Invokes same?.
An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
The record format that Lambda delivers to your function after schema validation.
-
Choose
JSONto have Lambda deliver the record to your function as a standard JSON object. -
Choose
SOURCEto 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.
The record format that Lambda delivers to your function after schema validation.
-
Choose
JSONto have Lambda deliver the record to your function as a standard JSON object. -
Choose
SOURCEto 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.
The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.
-
For Glue schema registries, use the ARN of the registry.
-
For Confluent schema registries, use the URL of the registry.
The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.
-
For Glue schema registries, use the ARN of the registry.
-
For Confluent schema registries, use the URL of the registry.
An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.