Class GlueSchemaRegistryProps

Properties for glue schema registry configuration.

Inheritance

object

GlueSchemaRegistryProps

Implements

IGlueSchemaRegistryProps

ISchemaRegistryProps

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Amazon.CDK.AWS.Lambda.EventSources

Assembly: Amazon.CDK.Lib.dll

Syntax (csharp)

public class GlueSchemaRegistryProps : IGlueSchemaRegistryProps, ISchemaRegistryProps

Syntax (vb)

Public Class GlueSchemaRegistryProps Implements IGlueSchemaRegistryProps, ISchemaRegistryProps

Remarks

ExampleMetadata: infused

Examples

using Amazon.CDK.AWS.Glue;
            using Amazon.CDK.AWS.Lambda.EventSources;

            // Your MSK cluster arn
            string clusterArn;

            Function myFunction;


            // The Kafka topic you want to subscribe to
            var topic = "some-cool-topic";

            // Your Glue Schema Registry
            var glueRegistry = new CfnRegistry(this, "Registry", new CfnRegistryProps {
                Name = "schema-registry",
                Description = "Schema registry for event source"
            });
            myFunction.AddEventSource(new ManagedKafkaEventSource(new ManagedKafkaEventSourceProps {
                ClusterArn = clusterArn,
                Topic = topic,
                StartingPosition = StartingPosition.TRIM_HORIZON,
                ProvisionedPollerConfig = new ProvisionedPollerConfig {
                    MinimumPollers = 1,
                    MaximumPollers = 3
                },
                SchemaRegistryConfig = new GlueSchemaRegistry(new GlueSchemaRegistryProps {
                    SchemaRegistry = glueRegistry,
                    EventRecordFormat = EventRecordFormat.JSON,
                    SchemaValidationConfigs = new [] { new KafkaSchemaValidationConfig { Attribute = KafkaSchemaValidationAttribute.KEY } }
                })
            }));

Synopsis

Constructors

GlueSchemaRegistryProps()

Properties for glue schema registry configuration.

Properties

EventRecordFormat	The record format that Lambda delivers to your function after schema validation.
SchemaRegistry	The CfnRegistry reference of your glue schema registry.
SchemaRegistryArn	The Arn of your glue schema registry.
SchemaValidationConfigs	An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.

Constructors

GlueSchemaRegistryProps()

Properties for glue schema registry configuration.

public GlueSchemaRegistryProps()

Remarks

ExampleMetadata: infused

Examples

using Amazon.CDK.AWS.Glue;
            using Amazon.CDK.AWS.Lambda.EventSources;

            // Your MSK cluster arn
            string clusterArn;

            Function myFunction;


            // The Kafka topic you want to subscribe to
            var topic = "some-cool-topic";

            // Your Glue Schema Registry
            var glueRegistry = new CfnRegistry(this, "Registry", new CfnRegistryProps {
                Name = "schema-registry",
                Description = "Schema registry for event source"
            });
            myFunction.AddEventSource(new ManagedKafkaEventSource(new ManagedKafkaEventSourceProps {
                ClusterArn = clusterArn,
                Topic = topic,
                StartingPosition = StartingPosition.TRIM_HORIZON,
                ProvisionedPollerConfig = new ProvisionedPollerConfig {
                    MinimumPollers = 1,
                    MaximumPollers = 3
                },
                SchemaRegistryConfig = new GlueSchemaRegistry(new GlueSchemaRegistryProps {
                    SchemaRegistry = glueRegistry,
                    EventRecordFormat = EventRecordFormat.JSON,
                    SchemaValidationConfigs = new [] { new KafkaSchemaValidationConfig { Attribute = KafkaSchemaValidationAttribute.KEY } }
                })
            }));

Properties

EventRecordFormat

The record format that Lambda delivers to your function after schema validation.

public EventRecordFormat EventRecordFormat { get; set; }

Property Value

EventRecordFormat

Remarks

Default: - none

SchemaRegistry

The CfnRegistry reference of your glue schema registry.

public CfnRegistry? SchemaRegistry { get; set; }

Property Value

CfnRegistry

Remarks

If used, schemaRegistryArn will be ignored.

Default: - none

SchemaRegistryArn

The Arn of your glue schema registry.

public string? SchemaRegistryArn { get; set; }

Property Value

string

Remarks

Default: - none

SchemaValidationConfigs

An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.

public IKafkaSchemaValidationConfig[] SchemaValidationConfigs { get; set; }

Property Value

IKafkaSchemaValidationConfig[]

Remarks

Default: - none

Implements

IGlueSchemaRegistryProps

ISchemaRegistryProps