software.amazon.awscdk.services.lambda.eventsources

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

Enclosing interface:

KafkaEventSourceProps

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 interface software.amazon.awscdk.services.lambda.eventsources.KafkaEventSourceProps

KafkaEventSourceProps.Builder, KafkaEventSourceProps.Jsii$Proxy

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef) Constructor that initializes the object based on values retrieved from the JsiiObject.

Method Summary

Modifier and Type	Method and Description
com.fasterxml.jackson.databind.JsonNode	$jsii$toJson()
boolean	equals(java.lang.Object o)
java.lang.Number	getBatchSize() The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.
java.lang.Boolean	getEnabled() If the stream event source mapping should be enabled.
Duration	getMaxBatchingWindow() The maximum amount of time to gather records before invoking the function.
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.
StartingPosition	getStartingPosition() Where to begin consuming the stream.
java.lang.String	getTopic() The Kafka topic to subscribe to.
int	hashCode()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

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

builder

Constructor Detail

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.

Method Detail

getTopic

public final java.lang.String getTopic()

Description copied from interface: KafkaEventSourceProps

The Kafka topic to subscribe to.

Specified by:

getTopic in interface KafkaEventSourceProps

getSecret

public final ISecret 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 interface KafkaEventSourceProps

getStartingPosition

public final StartingPosition getStartingPosition()

Description copied from interface: BaseStreamEventSourceProps

Where to begin consuming the stream.

Specified by:

getStartingPosition in interface BaseStreamEventSourceProps

getBatchSize

public final java.lang.Number 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 {@link DynamoEventSource}
  • 10000 for {@link KinesisEventSource}, {@link ManagedKafkaEventSource} and {@link SelfManagedKafkaEventSource}

Default: 100

Specified by:

getBatchSize in interface BaseStreamEventSourceProps

getEnabled

public final java.lang.Boolean getEnabled()

Description copied from interface: BaseStreamEventSourceProps

If the stream event source mapping should be enabled.

Default: true

Specified by:

getEnabled in interface BaseStreamEventSourceProps

getMaxBatchingWindow

public final Duration 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)

Specified by:

getMaxBatchingWindow in interface BaseStreamEventSourceProps

$jsii$toJson

public com.fasterxml.jackson.databind.JsonNode $jsii$toJson()

equals

public final boolean equals(java.lang.Object o)

hashCode

public final int hashCode()