Skip to content

/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