Uses of Class
software.amazon.awscdk.services.lambda.eventsources.SelfManagedKafkaEventSource.Builder
Packages that use SelfManagedKafkaEventSource.Builder
-
Uses of SelfManagedKafkaEventSource.Builder in software.amazon.awscdk.services.lambda.eventsources
Methods in software.amazon.awscdk.services.lambda.eventsources that return SelfManagedKafkaEventSource.BuilderModifier and TypeMethodDescriptionSelfManagedKafkaEventSource.Builder.authenticationMethod(AuthenticationMethod authenticationMethod) The authentication method for your Kafka cluster.The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.SelfManagedKafkaEventSource.Builder.bisectBatchOnError(Boolean bisectBatchOnError) If the function returns an error, split the batch in two and retry.SelfManagedKafkaEventSource.Builder.bootstrapServers(List<String> bootstrapServers) The list of host and port pairs that are the addresses of the Kafka brokers in a "bootstrap" Kafka cluster that a Kafka client connects to initially to bootstrap itself.SelfManagedKafkaEventSource.Builder.consumerGroupId(String consumerGroupId) The identifier for the Kafka consumer group to join.SelfManagedKafkaEventSource.Builder.create()If the stream event source mapping should be enabled.SelfManagedKafkaEventSource.Builder.filterEncryption(IKey filterEncryption) Add Customer managed KMS key to encrypt Filter Criteria.Add filter criteria to Event Source.SelfManagedKafkaEventSource.Builder.maxBatchingWindow(Duration maxBatchingWindow) The maximum amount of time to gather records before invoking the function.SelfManagedKafkaEventSource.Builder.maxRecordAge(Duration maxRecordAge) The maximum age of a record that Lambda sends to a function for processing.SelfManagedKafkaEventSource.Builder.onFailure(IEventSourceDlq onFailure) Add an on Failure Destination for this Kafka event.SelfManagedKafkaEventSource.Builder.provisionedPollerConfig(ProvisionedPollerConfig provisionedPollerConfig) Configuration for provisioned pollers that read from the event source.SelfManagedKafkaEventSource.Builder.reportBatchItemFailures(Boolean reportBatchItemFailures) Allow functions to return partially successful responses for a batch of records.SelfManagedKafkaEventSource.Builder.retryAttempts(Number retryAttempts) Maximum number of retry attempts.SelfManagedKafkaEventSource.Builder.rootCaCertificate(ISecret rootCaCertificate) The secret with the root CA certificate used by your Kafka brokers for TLS encryption This field is required if your Kafka brokers use certificates signed by a private CA.SelfManagedKafkaEventSource.Builder.schemaRegistryConfig(ISchemaRegistry schemaRegistryConfig) Specific configuration settings for a Kafka schema registry.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.SelfManagedKafkaEventSource.Builder.securityGroup(ISecurityGroup securityGroup) If your Kafka brokers are only reachable via VPC, provide the security group here.SelfManagedKafkaEventSource.Builder.startingPosition(StartingPosition startingPosition) Where to begin consuming the stream.SelfManagedKafkaEventSource.Builder.startingPositionTimestamp(Number startingPositionTimestamp) The time from which to start reading, in Unix time seconds.The Kafka topic to subscribe to.If your Kafka brokers are only reachable via VPC provide the VPC here.SelfManagedKafkaEventSource.Builder.vpcSubnets(SubnetSelection vpcSubnets) If your Kafka brokers are only reachable via VPC, provide the subnets selection here.