software.amazon.awscdk.services.lambda.eventsources

Class ManagedKafkaEventSourceProps.Builder

java.lang.Object

software.amazon.awscdk.services.lambda.eventsources.ManagedKafkaEventSourceProps.Builder

Enclosing interface:

ManagedKafkaEventSourceProps

public static final class ManagedKafkaEventSourceProps.Builder
extends java.lang.Object

A builder for ManagedKafkaEventSourceProps

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
ManagedKafkaEventSourceProps.Builder	batchSize(java.lang.Number batchSize) Sets the value of BaseStreamEventSourceProps.getBatchSize()
ManagedKafkaEventSourceProps	build() Builds the configured instance.
ManagedKafkaEventSourceProps.Builder	clusterArn(java.lang.String clusterArn) Sets the value of ManagedKafkaEventSourceProps.getClusterArn()
ManagedKafkaEventSourceProps.Builder	enabled(java.lang.Boolean enabled) Sets the value of BaseStreamEventSourceProps.getEnabled()
ManagedKafkaEventSourceProps.Builder	maxBatchingWindow(Duration maxBatchingWindow) Sets the value of BaseStreamEventSourceProps.getMaxBatchingWindow()
ManagedKafkaEventSourceProps.Builder	secret(ISecret secret) Sets the value of KafkaEventSourceProps.getSecret()
ManagedKafkaEventSourceProps.Builder	startingPosition(StartingPosition startingPosition) Sets the value of BaseStreamEventSourceProps.getStartingPosition()
ManagedKafkaEventSourceProps.Builder	topic(java.lang.String topic) Sets the value of KafkaEventSourceProps.getTopic()

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

clusterArn

public ManagedKafkaEventSourceProps.Builder clusterArn(java.lang.String clusterArn)

Sets the value of ManagedKafkaEventSourceProps.getClusterArn()

Parameters:

clusterArn - An MSK cluster construct. This parameter is required.

Returns:

this

topic

public ManagedKafkaEventSourceProps.Builder topic(java.lang.String topic)

Sets the value of KafkaEventSourceProps.getTopic()

Parameters:

topic - The Kafka topic to subscribe to. This parameter is required.

Returns:

this

secret

public ManagedKafkaEventSourceProps.Builder secret(ISecret secret)

Sets the value of KafkaEventSourceProps.getSecret()

Parameters:

secret - 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.

Returns:

this

startingPosition

public ManagedKafkaEventSourceProps.Builder startingPosition(StartingPosition startingPosition)

Sets the value of BaseStreamEventSourceProps.getStartingPosition()

Parameters:

startingPosition - Where to begin consuming the stream. This parameter is required.

Returns:

this

batchSize

public ManagedKafkaEventSourceProps.Builder batchSize(java.lang.Number batchSize)

Sets the value of BaseStreamEventSourceProps.getBatchSize()

Parameters:

batchSize - 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}

Returns:

this

enabled

public ManagedKafkaEventSourceProps.Builder enabled(java.lang.Boolean enabled)

Sets the value of BaseStreamEventSourceProps.getEnabled()

Parameters:

enabled - If the stream event source mapping should be enabled.

Returns:

this

maxBatchingWindow

public ManagedKafkaEventSourceProps.Builder maxBatchingWindow(Duration maxBatchingWindow)

Sets the value of BaseStreamEventSourceProps.getMaxBatchingWindow()

Parameters:

maxBatchingWindow - The maximum amount of time to gather records before invoking the function. Maximum of Duration.minutes(5)

Returns:

this

build

public ManagedKafkaEventSourceProps build()

Builds the configured instance.

Returns:

a new instance of ManagedKafkaEventSourceProps

Throws:

java.lang.NullPointerException - if any required attribute was not provided