Uses of Class
software.amazon.awscdk.services.lambda.eventsources.ManagedKafkaEventSource.Builder
Packages that use ManagedKafkaEventSource.Builder
-
Uses of ManagedKafkaEventSource.Builder in software.amazon.awscdk.services.lambda.eventsources
Methods in software.amazon.awscdk.services.lambda.eventsources that return ManagedKafkaEventSource.BuilderModifier and TypeMethodDescriptionThe largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.ManagedKafkaEventSource.Builder.clusterArn
(String clusterArn) An MSK cluster construct.ManagedKafkaEventSource.Builder.consumerGroupId
(String consumerGroupId) The identifier for the Kafka consumer group to join.ManagedKafkaEventSource.Builder.create()
If the stream event source mapping should be enabled.ManagedKafkaEventSource.Builder.filterEncryption
(IKey filterEncryption) Add Customer managed KMS key to encrypt Filter Criteria.Add filter criteria to Event Source.ManagedKafkaEventSource.Builder.maxBatchingWindow
(Duration maxBatchingWindow) The maximum amount of time to gather records before invoking the function.ManagedKafkaEventSource.Builder.onFailure
(IEventSourceDlq onFailure) Add an on Failure Destination for this Kafka event.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.startingPosition
(StartingPosition startingPosition) Where to begin consuming the stream.The Kafka topic to subscribe to.