interface CfnRegistryProps
Language | Type name |
---|---|
![]() | Amazon.CDK.AWS.Glue.CfnRegistryProps |
![]() | github.com/aws/aws-cdk-go/awscdk/v2/awsglue#CfnRegistryProps |
![]() | software.amazon.awscdk.services.glue.CfnRegistryProps |
![]() | aws_cdk.aws_glue.CfnRegistryProps |
![]() | aws-cdk-lib » aws_glue » CfnRegistryProps |
Properties for defining a CfnRegistry
.
See also: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-glue-registry.html
Example
import { CfnRegistry } from 'aws-cdk-lib/aws-glue';
import { ManagedKafkaEventSource, GlueSchemaRegistry } from 'aws-cdk-lib/aws-lambda-event-sources';
// Your MSK cluster arn
declare const clusterArn: string;
// The Kafka topic you want to subscribe to
const topic = 'some-cool-topic';
// Your Glue Schema Registry
const glueRegistry = new CfnRegistry(this, 'Registry', {
name: 'schema-registry',
description: 'Schema registry for event source',
});
declare const myFunction: lambda.Function;
myFunction.addEventSource(new ManagedKafkaEventSource({
clusterArn,
topic,
startingPosition: lambda.StartingPosition.TRIM_HORIZON,
provisionedPollerConfig: {
minimumPollers: 1,
maximumPollers: 3,
},
schemaRegistryConfig: new GlueSchemaRegistry({
schemaRegistry: glueRegistry,
eventRecordFormat: lambda.EventRecordFormat.JSON,
schemaValidationConfigs: [{ attribute: lambda.KafkaSchemaValidationAttribute.KEY }],
}),
}));
Properties
Name | Type | Description |
---|---|---|
name | string | The name of the registry. |
description? | string | A description of the registry. |
tags? | Cfn [] | AWS tags that contain a key value pair and may be searched by console, command line, or API. |
name
Type:
string
The name of the registry.
description?
Type:
string
(optional)
A description of the registry.
tags?
Type:
Cfn
[]
(optional)
AWS tags that contain a key value pair and may be searched by console, command line, or API.