public static final class KafkaEventSourceProps.Builder
extends java.lang.Object
KafkaEventSourceProps
Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
KafkaEventSourceProps.Builder |
batchSize(java.lang.Number batchSize)
Sets the value of
BaseStreamEventSourceProps.getBatchSize() |
KafkaEventSourceProps |
build()
Builds the configured instance.
|
KafkaEventSourceProps.Builder |
enabled(java.lang.Boolean enabled)
Sets the value of
BaseStreamEventSourceProps.getEnabled() |
KafkaEventSourceProps.Builder |
maxBatchingWindow(Duration maxBatchingWindow)
Sets the value of
BaseStreamEventSourceProps.getMaxBatchingWindow() |
KafkaEventSourceProps.Builder |
secret(ISecret secret)
Sets the value of
KafkaEventSourceProps.getSecret() |
KafkaEventSourceProps.Builder |
startingPosition(StartingPosition startingPosition)
Sets the value of
BaseStreamEventSourceProps.getStartingPosition() |
KafkaEventSourceProps.Builder |
topic(java.lang.String topic)
Sets the value of
KafkaEventSourceProps.getTopic() |
public KafkaEventSourceProps.Builder topic(java.lang.String topic)
KafkaEventSourceProps.getTopic()
topic
- The Kafka topic to subscribe to. This parameter is required.this
public KafkaEventSourceProps.Builder secret(ISecret secret)
KafkaEventSourceProps.getSecret()
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.this
public KafkaEventSourceProps.Builder startingPosition(StartingPosition startingPosition)
BaseStreamEventSourceProps.getStartingPosition()
startingPosition
- Where to begin consuming the stream. This parameter is required.this
public KafkaEventSourceProps.Builder batchSize(java.lang.Number batchSize)
BaseStreamEventSourceProps.getBatchSize()
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:
this
public KafkaEventSourceProps.Builder enabled(java.lang.Boolean enabled)
BaseStreamEventSourceProps.getEnabled()
enabled
- If the stream event source mapping should be enabled.this
public KafkaEventSourceProps.Builder maxBatchingWindow(Duration maxBatchingWindow)
BaseStreamEventSourceProps.getMaxBatchingWindow()
maxBatchingWindow
- The maximum amount of time to gather records before invoking the function.
Maximum of Duration.minutes(5)this
public KafkaEventSourceProps build()
KafkaEventSourceProps
java.lang.NullPointerException
- if any required attribute was not provided