Pipe
data class PipeSourceKinesisStreamParametersArgs(val batchSize: Output<Int>? = null, val deadLetterConfig: Output<PipeDeadLetterConfigArgs>? = null, val maximumBatchingWindowInSeconds: Output<Int>? = null, val maximumRecordAgeInSeconds: Output<Int>? = null, val maximumRetryAttempts: Output<Int>? = null, val onPartialBatchItemFailure: Output<PipeOnPartialBatchItemFailureStreams>? = null, val parallelizationFactor: Output<Int>? = null, val startingPosition: Output<PipeKinesisStreamStartPosition>, val startingPositionTimestamp: Output<String>? = null) : ConvertibleToJava<PipeSourceKinesisStreamParametersArgs>
Constructors
Link copied to clipboard
fun PipeSourceKinesisStreamParametersArgs(batchSize: Output<Int>? = null, deadLetterConfig: Output<PipeDeadLetterConfigArgs>? = null, maximumBatchingWindowInSeconds: Output<Int>? = null, maximumRecordAgeInSeconds: Output<Int>? = null, maximumRetryAttempts: Output<Int>? = null, onPartialBatchItemFailure: Output<PipeOnPartialBatchItemFailureStreams>? = null, parallelizationFactor: Output<Int>? = null, startingPosition: Output<PipeKinesisStreamStartPosition>, startingPositionTimestamp: Output<String>? = null)