SelfManagedKafkaEventSourceConfigProperty Struct
Specific configuration settings for a self-managed Apache Kafka event source.
Example
ts
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import { aws_lambda as lambda } from 'aws-cdk-lib';
const selfManagedKafkaEventSourceConfigProperty: lambda.CfnEventSourceMapping.SelfManagedKafkaEventSourceConfigProperty = {
consumerGroupId: 'consumerGroupId',
consumptionMode: 'consumptionMode',
schemaRegistryConfig: {
accessConfigs: [{
type: 'type',
uri: 'uri',
}],
eventRecordFormat: 'eventRecordFormat',
schemaRegistryUri: 'schemaRegistryUri',
schemaValidationConfigs: [{
attribute: 'attribute',
}],
},
};
Properties
consumerGroupIdstringconsumer_group_idstrconsumerGroupIdStringConsumerGroupIdstringConsumerGroupId*string#The identifier for the Kafka consumer group to join.
notes
The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID .
consumptionModestringconsumption_modestrconsumptionModeStringConsumptionModestringConsumptionMode*string#The mode that determines how Lambda reads from a Kafka topic.
Use Stream for ordered processing or Queue for higher throughput when ordering is not required.
schemaRegistryConfigIResolvable | CfnEventSourceMapping.SchemaRegistryConfigPropertyschema_registry_configtyping.Union[IResolvable, SchemaRegistryConfigProperty]schemaRegistryConfigIResolvableSchemaRegistryConfigIResolvableSchemaRegistryConfiginterface{}#Specific configuration settings for a Kafka schema registry.