Class KafkaEventSourceProps.Jsii$Proxy
java.lang.Object
software.amazon.jsii.JsiiObject
software.amazon.awscdk.services.lambda.eventsources.KafkaEventSourceProps.Jsii$Proxy
- All Implemented Interfaces:
BaseStreamEventSourceProps
,KafkaEventSourceProps
,software.amazon.jsii.JsiiSerializable
- Enclosing interface:
KafkaEventSourceProps
@Stability(Stable)
@Internal
public static final class KafkaEventSourceProps.Jsii$Proxy
extends software.amazon.jsii.JsiiObject
implements KafkaEventSourceProps
An implementation for
KafkaEventSourceProps
-
Nested Class Summary
Nested classes/interfaces inherited from class software.amazon.jsii.JsiiObject
software.amazon.jsii.JsiiObject.InitializationMode
Nested classes/interfaces inherited from interface software.amazon.awscdk.services.lambda.eventsources.KafkaEventSourceProps
KafkaEventSourceProps.Builder, KafkaEventSourceProps.Jsii$Proxy
-
Constructor Summary
ModifierConstructorDescriptionprotected
Jsii$Proxy
(KafkaEventSourceProps.Builder builder) Constructor that initializes the object based on literal property values passed by theKafkaEventSourceProps.Builder
.protected
Jsii$Proxy
(software.amazon.jsii.JsiiObjectRef objRef) Constructor that initializes the object based on values retrieved from the JsiiObject. -
Method Summary
Modifier and TypeMethodDescriptioncom.fasterxml.jackson.databind.JsonNode
final boolean
final Number
The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.final String
The identifier for the Kafka consumer group to join.final Boolean
If the stream event source mapping should be enabled.final IKey
Add Customer managed KMS key to encrypt Filter Criteria.Add filter criteria to Event Source.final Duration
The maximum amount of time to gather records before invoking the function.final IEventSourceDlq
Add an on Failure Destination for this Kafka event.final ISecret
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.final StartingPosition
Where to begin consuming the stream.final String
getTopic()
The Kafka topic to subscribe to.final int
hashCode()
Methods inherited from class software.amazon.jsii.JsiiObject
jsiiAsyncCall, jsiiAsyncCall, jsiiCall, jsiiCall, jsiiGet, jsiiGet, jsiiSet, jsiiStaticCall, jsiiStaticCall, jsiiStaticGet, jsiiStaticGet, jsiiStaticSet, jsiiStaticSet
-
Constructor Details
-
Jsii$Proxy
protected Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef) Constructor that initializes the object based on values retrieved from the JsiiObject.- Parameters:
objRef
- Reference to the JSII managed object.
-
Jsii$Proxy
Constructor that initializes the object based on literal property values passed by theKafkaEventSourceProps.Builder
.
-
-
Method Details
-
getTopic
Description copied from interface:KafkaEventSourceProps
The Kafka topic to subscribe to.- Specified by:
getTopic
in interfaceKafkaEventSourceProps
-
getConsumerGroupId
Description copied from interface:KafkaEventSourceProps
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
- Specified by:
getConsumerGroupId
in interfaceKafkaEventSourceProps
- See Also:
-
getFilterEncryption
Description copied from interface:KafkaEventSourceProps
Add Customer managed KMS key to encrypt Filter Criteria.Default: - none
- Specified by:
getFilterEncryption
in interfaceKafkaEventSourceProps
- See Also:
-
getFilters
Description copied from interface:KafkaEventSourceProps
Add filter criteria to Event Source.Default: - none
- Specified by:
getFilters
in interfaceKafkaEventSourceProps
- See Also:
-
getOnFailure
Description copied from interface:KafkaEventSourceProps
Add an on Failure Destination for this Kafka event.SNS/SQS/S3 are supported
Default: - discarded records are ignored
- Specified by:
getOnFailure
in interfaceKafkaEventSourceProps
-
getSecret
Description copied from interface:KafkaEventSourceProps
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
- Specified by:
getSecret
in interfaceKafkaEventSourceProps
-
getStartingPosition
Description copied from interface:BaseStreamEventSourceProps
Where to begin consuming the stream.- Specified by:
getStartingPosition
in interfaceBaseStreamEventSourceProps
-
getBatchSize
Description copied from interface:BaseStreamEventSourceProps
The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.Your function receives an event with all the retrieved records.
Valid Range:
- Minimum value of 1
- Maximum value of:
- 1000 for
DynamoEventSource
- 10000 for
KinesisEventSource
,ManagedKafkaEventSource
andSelfManagedKafkaEventSource
- 1000 for
Default: 100
- Specified by:
getBatchSize
in interfaceBaseStreamEventSourceProps
-
getEnabled
Description copied from interface:BaseStreamEventSourceProps
If the stream event source mapping should be enabled.Default: true
- Specified by:
getEnabled
in interfaceBaseStreamEventSourceProps
-
getMaxBatchingWindow
Description copied from interface:BaseStreamEventSourceProps
The maximum amount of time to gather records before invoking the function.Maximum of Duration.minutes(5).
Default: - Duration.seconds(0) for Kinesis, DynamoDB, and SQS event sources, Duration.millis(500) for MSK, self-managed Kafka, and Amazon MQ.
- Specified by:
getMaxBatchingWindow
in interfaceBaseStreamEventSourceProps
- See Also:
-
$jsii$toJson
@Internal public com.fasterxml.jackson.databind.JsonNode $jsii$toJson()- Specified by:
$jsii$toJson
in interfacesoftware.amazon.jsii.JsiiSerializable
-
equals
-
hashCode
public final int hashCode()
-