Package software.amazon.awscdk.services.lambda.eventsources

Class GlueSchemaRegistry

java.lang.Object

software.amazon.jsii.JsiiObject

software.amazon.awscdk.services.lambda.eventsources.GlueSchemaRegistry

All Implemented Interfaces:

ISchemaRegistry, software.amazon.jsii.JsiiSerializable

@Generated(value="jsii-pacmak/1.121.0 (build d7af9b9)",
           date="2025-12-18T18:20:12.858Z")
@Stability(Stable)
public class GlueSchemaRegistry
extends software.amazon.jsii.JsiiObject
implements ISchemaRegistry

Glue schema registry configuration for a Lambda event source.

Example:

 import software.amazon.awscdk.services.glue.CfnRegistry;
 import software.amazon.awscdk.services.lambda.eventsources.ManagedKafkaEventSource;
 import software.amazon.awscdk.services.lambda.eventsources.GlueSchemaRegistry;
 // Your MSK cluster arn
 String clusterArn;
 Function myFunction;
 // The Kafka topic you want to subscribe to
 String topic = "some-cool-topic";
 // Your Glue Schema Registry
 CfnRegistry glueRegistry = CfnRegistry.Builder.create(this, "Registry")
         .name("schema-registry")
         .description("Schema registry for event source")
         .build();
 myFunction.addEventSource(ManagedKafkaEventSource.Builder.create()
         .clusterArn(clusterArn)
         .topic(topic)
         .startingPosition(StartingPosition.TRIM_HORIZON)
         .provisionedPollerConfig(ProvisionedPollerConfig.builder()
                 .minimumPollers(1)
                 .maximumPollers(3)
                 .build())
         .schemaRegistryConfig(GlueSchemaRegistry.Builder.create()
                 .schemaRegistry(glueRegistry)
                 .eventRecordFormat(EventRecordFormat.JSON)
                 .schemaValidationConfigs(List.of(KafkaSchemaValidationConfig.builder().attribute(KafkaSchemaValidationAttribute.KEY).build()))
                 .build())
         .build());
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	GlueSchemaRegistry.Builder	A fluent builder for GlueSchemaRegistry.

Nested classes/interfaces inherited from class software.amazon.jsii.JsiiObject

software.amazon.jsii.JsiiObject.InitializationMode

Nested classes/interfaces inherited from interface software.amazon.awscdk.services.lambda.ISchemaRegistry

ISchemaRegistry.Jsii$Default, ISchemaRegistry.Jsii$Proxy

Constructor Summary

Constructors

Modifier	Constructor	Description
	GlueSchemaRegistry(GlueSchemaRegistryProps props)
protected	GlueSchemaRegistry(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
protected	GlueSchemaRegistry(software.amazon.jsii.JsiiObjectRef objRef)

Method Summary

Modifier and Type	Method	Description
KafkaSchemaRegistryConfig	bind(IEventSourceMapping _target, IFunction targetHandler)	Returns a schema registry configuration.

Methods inherited from class software.amazon.jsii.JsiiObject

jsiiAsyncCall, jsiiAsyncCall, jsiiCall, jsiiCall, jsiiGet, jsiiGet, jsiiSet, jsiiStaticCall, jsiiStaticCall, jsiiStaticGet, jsiiStaticGet, jsiiStaticSet, jsiiStaticSet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface software.amazon.jsii.JsiiSerializable

$jsii$toJson

Constructor Details

GlueSchemaRegistry

protected GlueSchemaRegistry(software.amazon.jsii.JsiiObjectRef objRef)

GlueSchemaRegistry

protected GlueSchemaRegistry(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

GlueSchemaRegistry

@Stability(Stable)
public GlueSchemaRegistry(@NotNull
 GlueSchemaRegistryProps props)

Parameters:

props - This parameter is required.

Method Details

bind

@Stability(Stable)
@NotNull
public KafkaSchemaRegistryConfig bind(@NotNull
 IEventSourceMapping _target,
 @NotNull
 IFunction targetHandler)

Returns a schema registry configuration.

Specified by:

bind in interface ISchemaRegistry

Parameters:

_target - This parameter is required.

targetHandler - This parameter is required.