Values.UpdatePipeSourceKinesisStreamParametersSourceThe parameters for using a Kinesis stream as a source.
type nonrec t = {batchSize : LimitMax10000.t option;The maximum number of records to include in each batch.
*)deadLetterConfig : DeadLetterConfig.t option;Define the target queue to send dead-letter queue events to.
*)onPartialBatchItemFailure : OnPartialBatchItemFailureStreams.t option;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.
*)maximumBatchingWindowInSeconds : MaximumBatchingWindowInSeconds.t option;The maximum length of a time to wait for events.
*)maximumRecordAgeInSeconds : MaximumRecordAgeInSeconds.t option;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 : MaximumRetryAttemptsESM.t option;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.
*)parallelizationFactor : LimitMax10.t option;The number of batches to process concurrently from each shard. The default value is 1.
*)}val to_value :
t ->
[> `Structure of
(string
* [> `Enum of string
| `Integer of LimitMax10000.t
| `Structure of (string * [> `String of Arn.t ]) list ])
list ]