Class CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder
java.lang.Object
software.amazon.awscdk.cfnpropertymixins.services.pipes.CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder
- All Implemented Interfaces:
software.amazon.jsii.Builder<CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty>
- Enclosing interface:
CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty
@Stability(Stable)
public static final class CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder
extends Object
implements software.amazon.jsii.Builder<CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbuild()Builds the configured instance.deadLetterConfig(CfnPipePropsMixin.DeadLetterConfigProperty deadLetterConfig) deadLetterConfig(IResolvable deadLetterConfig) maximumBatchingWindowInSeconds(Number maximumBatchingWindowInSeconds) maximumRecordAgeInSeconds(Number maximumRecordAgeInSeconds) maximumRetryAttempts(Number maximumRetryAttempts) onPartialBatchItemFailure(String onPartialBatchItemFailure) parallelizationFactor(Number parallelizationFactor) startingPosition(String startingPosition) startingPositionTimestamp(String startingPositionTimestamp)
-
Constructor Details
-
Builder
public Builder()
-
-
Method Details
-
batchSize
@Stability(Stable) public CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder batchSize(Number batchSize) - Parameters:
batchSize- The maximum number of records to include in each batch.- Returns:
this
-
deadLetterConfig
@Stability(Stable) public CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder deadLetterConfig(IResolvable deadLetterConfig) - Parameters:
deadLetterConfig- Define the target queue to send dead-letter queue events to.- Returns:
this
-
deadLetterConfig
@Stability(Stable) public CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder deadLetterConfig(CfnPipePropsMixin.DeadLetterConfigProperty deadLetterConfig) - Parameters:
deadLetterConfig- Define the target queue to send dead-letter queue events to.- Returns:
this
-
maximumBatchingWindowInSeconds
@Stability(Stable) public CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder maximumBatchingWindowInSeconds(Number maximumBatchingWindowInSeconds) Sets the value ofCfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.getMaximumBatchingWindowInSeconds()- Parameters:
maximumBatchingWindowInSeconds- The maximum length of a time to wait for events.- Returns:
this
-
maximumRecordAgeInSeconds
@Stability(Stable) public CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder maximumRecordAgeInSeconds(Number maximumRecordAgeInSeconds) Sets the value ofCfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.getMaximumRecordAgeInSeconds()- Parameters:
maximumRecordAgeInSeconds- 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.- Returns:
this
-
maximumRetryAttempts
@Stability(Stable) public CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder maximumRetryAttempts(Number maximumRetryAttempts) Sets the value ofCfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.getMaximumRetryAttempts()- Parameters:
maximumRetryAttempts- 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.- Returns:
this
-
onPartialBatchItemFailure
@Stability(Stable) public CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder onPartialBatchItemFailure(String onPartialBatchItemFailure) Sets the value ofCfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.getOnPartialBatchItemFailure()- Parameters:
onPartialBatchItemFailure- Define how to handle item process failures.AUTOMATIC_BISECThalves each batch and retry each half until all the records are processed or there is one failed message left in the batch.- Returns:
this
-
parallelizationFactor
@Stability(Stable) public CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder parallelizationFactor(Number parallelizationFactor) Sets the value ofCfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.getParallelizationFactor()- Parameters:
parallelizationFactor- The number of batches to process concurrently from each shard. The default value is 1.- Returns:
this
-
startingPosition
@Stability(Stable) public CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder startingPosition(String startingPosition) - Parameters:
startingPosition- The position in a stream from which to start reading.- Returns:
this
-
startingPositionTimestamp
@Stability(Stable) public CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.Builder startingPositionTimestamp(String startingPositionTimestamp) Sets the value ofCfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty.getStartingPositionTimestamp()- Parameters:
startingPositionTimestamp- WithStartingPositionset toAT_TIMESTAMP, the time from which to start reading, in Unix time seconds.- Returns:
this
-
build
Builds the configured instance.- Specified by:
buildin interfacesoftware.amazon.jsii.Builder<CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty>- Returns:
- a new instance of
CfnPipePropsMixin.PipeSourceKinesisStreamParametersProperty - Throws:
NullPointerException- if any required attribute was not provided
-