/AWS1/CL_LMDKAFKASCHREGCONFIG¶
Specific configuration settings for a Kafka schema registry.
CONSTRUCTOR
¶
IMPORTING¶
Optional arguments:¶
iv_schemaregistryuri
TYPE /AWS1/LMDSCHEMAREGISTRYURI
/AWS1/LMDSCHEMAREGISTRYURI
¶
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.
iv_eventrecordformat
TYPE /AWS1/LMDSCHREGEVENTRECFORMAT
/AWS1/LMDSCHREGEVENTRECFORMAT
¶
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.
it_accessconfigs
TYPE /AWS1/CL_LMDKAFKASCHREGACCCFG=>TT_KAFKASCHREGACCESSCONFIGLIST
TT_KAFKASCHREGACCESSCONFIGLIST
¶
An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
it_schemavalidationconfigs
TYPE /AWS1/CL_LMDKAFKASCHVALIDATI00=>TT_KAFKASCHVALIDATIONCFGLIST
TT_KAFKASCHVALIDATIONCFGLIST
¶
An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
Queryable Attributes¶
SchemaRegistryURI¶
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.
Accessible with the following methods¶
Method | Description |
---|---|
GET_SCHEMAREGISTRYURI() |
Getter for SCHEMAREGISTRYURI, with configurable default |
ASK_SCHEMAREGISTRYURI() |
Getter for SCHEMAREGISTRYURI w/ exceptions if field has no v |
HAS_SCHEMAREGISTRYURI() |
Determine if SCHEMAREGISTRYURI has a value |
EventRecordFormat¶
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.
Accessible with the following methods¶
Method | Description |
---|---|
GET_EVENTRECORDFORMAT() |
Getter for EVENTRECORDFORMAT, with configurable default |
ASK_EVENTRECORDFORMAT() |
Getter for EVENTRECORDFORMAT w/ exceptions if field has no v |
HAS_EVENTRECORDFORMAT() |
Determine if EVENTRECORDFORMAT has a value |
AccessConfigs¶
An array of access configuration objects that tell Lambda how to authenticate with your schema registry.
Accessible with the following methods¶
Method | Description |
---|---|
GET_ACCESSCONFIGS() |
Getter for ACCESSCONFIGS, with configurable default |
ASK_ACCESSCONFIGS() |
Getter for ACCESSCONFIGS w/ exceptions if field has no value |
HAS_ACCESSCONFIGS() |
Determine if ACCESSCONFIGS has a value |
SchemaValidationConfigs¶
An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.
Accessible with the following methods¶
Method | Description |
---|---|
GET_SCHEMAVALIDATIONCONFIGS() |
Getter for SCHEMAVALIDATIONCONFIGS, with configurable defaul |
ASK_SCHEMAVALIDATIONCONFIGS() |
Getter for SCHEMAVALIDATIONCONFIGS w/ exceptions if field ha |
HAS_SCHEMAVALIDATIONCONFIGS() |
Determine if SCHEMAVALIDATIONCONFIGS has a value |