pipes/aws.sdk.kotlin.services.pipes.model/UpdatePipeSourceDynamoDbStreamParameters/Builder

Builder

class Builder

Properties

batchSize

var batchSize: Int?

The maximum number of records to include in each batch.

deadLetterConfig

var deadLetterConfig: DeadLetterConfig?

Define the target queue to send dead-letter queue events to.

maximumBatchingWindowInSeconds

var maximumBatchingWindowInSeconds: Int?

The maximum length of a time to wait for events.

maximumRecordAgeInSeconds

var maximumRecordAgeInSeconds: Int?

Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.

maximumRetryAttempts

var maximumRetryAttempts: Int?

Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.

onPartialBatchItemFailure

var onPartialBatchItemFailure: OnPartialBatchItemFailureStreams?

Define how to handle item process failures. AUTOMATIC_BISECT halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.

parallelizationFactor

var parallelizationFactor: Int?

The number of batches to process concurrently from each shard. The default value is 1.

Functions

deadLetterConfig

fun deadLetterConfig(block: DeadLetterConfig.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.pipes.model.DeadLetterConfig inside the given block