Package software.amazon.awscdk.services.lambda.eventsources

Interface KafkaEventSourceProps

All Superinterfaces:

BaseStreamEventSourceProps, software.amazon.jsii.JsiiSerializable

All Known Subinterfaces:

ManagedKafkaEventSourceProps, SelfManagedKafkaEventSourceProps

All Known Implementing Classes:

KafkaEventSourceProps.Jsii$Proxy, ManagedKafkaEventSourceProps.Jsii$Proxy, SelfManagedKafkaEventSourceProps.Jsii$Proxy

@Generated(value="jsii-pacmak/1.104.0 (build e79254c)",
           date="2024-11-22T02:24:04.002Z")
@Stability(Stable)
public interface KafkaEventSourceProps
extends software.amazon.jsii.JsiiSerializable, BaseStreamEventSourceProps

Properties for a Kafka event source.

Example:

 // The code below shows an example of how to instantiate this type.
 // The values are placeholders you should change.
 import software.amazon.awscdk.*;
 import software.amazon.awscdk.services.kms.*;
 import software.amazon.awscdk.services.lambda.*;
 import software.amazon.awscdk.services.lambda.eventsources.*;
 import software.amazon.awscdk.services.secretsmanager.*;
 IEventSourceDlq eventSourceDlq;
 Object filters;
 Key key;
 Secret secret;
 KafkaEventSourceProps kafkaEventSourceProps = KafkaEventSourceProps.builder()
         .startingPosition(StartingPosition.TRIM_HORIZON)
         .topic("topic")
         // the properties below are optional
         .batchSize(123)
         .consumerGroupId("consumerGroupId")
         .enabled(false)
         .filterEncryption(key)
         .filters(List.of(Map.of(
                 "filtersKey", filters)))
         .maxBatchingWindow(Duration.minutes(30))
         .onFailure(eventSourceDlq)
         .provisionedPollerConfig(ProvisionedPollerConfig.builder()
                 .maximumPollers(123)
                 .minimumPollers(123)
                 .build())
         .secret(secret)
         .build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final class	KafkaEventSourceProps.Builder	A builder for KafkaEventSourceProps
static final class	KafkaEventSourceProps.Jsii$Proxy	An implementation for KafkaEventSourceProps

Method Summary

Modifier and Type	Method	Description
static KafkaEventSourceProps.Builder	builder()
default String	getConsumerGroupId()	The identifier for the Kafka consumer group to join.
default IKey	getFilterEncryption()	Add Customer managed KMS key to encrypt Filter Criteria.
default List<Map<String,Object>>	getFilters()	Add filter criteria to Event Source.
default IEventSourceDlq	getOnFailure()	Add an on Failure Destination for this Kafka event.
default ISecret	getSecret()	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.
String	getTopic()	The Kafka topic to subscribe to.

Methods inherited from interface software.amazon.awscdk.services.lambda.eventsources.BaseStreamEventSourceProps

getBatchSize, getEnabled, getMaxBatchingWindow, getProvisionedPollerConfig, getStartingPosition

Methods inherited from interface software.amazon.jsii.JsiiSerializable

$jsii$toJson

Method Details

getTopic

@Stability(Stable)
@NotNull
String getTopic()

The Kafka topic to subscribe to.

getConsumerGroupId

@Stability(Stable)
@Nullable
default String getConsumerGroupId()

The identifier for the Kafka consumer group to join.

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. The value must have a lenght between 1 and 200 and full the pattern '[a-zA-Z0-9-/:_+=.@-]'.

Default: - none

See Also:

• https://docs.aws.amazon.com/lambda/latest/dg/with-msk.html#services-msk-consumer-group-id

getFilterEncryption

@Stability(Stable)
@Nullable
default IKey getFilterEncryption()

Add Customer managed KMS key to encrypt Filter Criteria.

Default: - none

See Also:

• https://docs.aws.amazon.com/kms/latest/developerguide/concepts.html#aws-managed-cmk

getFilters

@Stability(Stable)
@Nullable
default List<Map<String,Object>> getFilters()

Add filter criteria to Event Source.

Default: - none

See Also:

• https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html

getOnFailure

@Stability(Stable)
@Nullable
default IEventSourceDlq getOnFailure()

Add an on Failure Destination for this Kafka event.

SNS/SQS/S3 are supported

Default: - discarded records are ignored

getSecret

@Stability(Stable)
@Nullable
default ISecret getSecret()

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.

Default: none

builder

@Stability(Stable)
static KafkaEventSourceProps.Builder builder()

Returns:

a KafkaEventSourceProps.Builder of KafkaEventSourceProps