Uses of Class
software.amazon.awscdk.services.lambda.eventsources.ManagedKafkaEventSource.Builder

Packages that use ManagedKafkaEventSource.Builder

Package	Description
software.amazon.awscdk.services.lambda.eventsources	AWS Lambda Event Sources

Uses of ManagedKafkaEventSource.Builder in software.amazon.awscdk.services.lambda.eventsources

Methods in software.amazon.awscdk.services.lambda.eventsources that return ManagedKafkaEventSource.Builder

Modifier and Type	Method	Description
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.batchSize(Number batchSize)	The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.bisectBatchOnError(Boolean bisectBatchOnError)	If the function returns an error, split the batch in two and retry.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.clusterArn(String clusterArn)	An MSK cluster construct.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.consumerGroupId(String consumerGroupId)	The identifier for the Kafka consumer group to join.
static ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.create()
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.enabled(Boolean enabled)	If the stream event source mapping should be enabled.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.filterEncryption(IKey filterEncryption)	Add Customer managed KMS key to encrypt Filter Criteria.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.filters(List<? extends Map<String,? extends Object>> filters)	Add filter criteria to Event Source.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.maxBatchingWindow(Duration maxBatchingWindow)	The maximum amount of time to gather records before invoking the function.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.maxRecordAge(Duration maxRecordAge)	The maximum age of a record that Lambda sends to a function for processing.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.onFailure(IEventSourceDlq onFailure)	Add an on Failure Destination for this Kafka event.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.provisionedPollerConfig(ProvisionedPollerConfig provisionedPollerConfig)	Configuration for provisioned pollers that read from the event source.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.reportBatchItemFailures(Boolean reportBatchItemFailures)	Allow functions to return partially successful responses for a batch of records.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.retryAttempts(Number retryAttempts)	Maximum number of retry attempts.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.schemaRegistryConfig(ISchemaRegistry schemaRegistryConfig)	Specific configuration settings for a Kafka schema registry.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.secret(ISecret secret)	The secret with the Kafka credentials, see https://docs.aws.amazon.com/msk/latest/developerguide/msk-password.html for details This field is required if your Kafka brokers are accessed over the Internet.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.startingPosition(StartingPosition startingPosition)	Where to begin consuming the stream.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.startingPositionTimestamp(Number startingPositionTimestamp)	The time from which to start reading, in Unix time seconds.
ManagedKafkaEventSource.Builder	ManagedKafkaEventSource.Builder.topic(String topic)	The Kafka topic to subscribe to.