AwsEventbridgePipeSourceKinesisStreamArgs

interface AwsEventbridgePipeSourceKinesisStreamArgs extends EventbridgePipeSourceStreamBaseArgs {
batchSize?: Input<number>;
deadLetterConfig?: AwsEventbridgePipeSourceDeadLetterConfigArgs;
maximumBatchingWindowInSeconds?: Input<number>;
maximumRecordAgeInSeconds?: Input<number>;
maximumRetryAttempts?: Input<number>;
onPartialBatchItemFailure?: Input<string>;
parallelizationFactor?: Input<number>;
startingPosition: Input<'TRIM_HORIZON' | 'LATEST' | 'AT_TIMESTAMP'>;
startingPositionTimestamp?: Input<string>;
}

Source parameters for a Kinesis Data Streams source.

Hierarchy

EventbridgePipeSourceStreamBaseArgs
AwsEventbridgePipeSourceKinesisStreamArgs

Properties

`batchSize: Input<number>`

Inherited from batchSize

Maximum number of records per batch. Maximum value: 10000.

`deadLetterConfig: AwsEventbridgePipeSourceDeadLetterConfigArgs`

Inherited from deadLetterConfig

Dead-letter configuration for failed records.

`maximumBatchingWindowInSeconds: Input<number>`

Inherited from maximumBatchingWindowInSeconds

Maximum time in seconds to wait before dispatching a batch. Maximum value: 300.

`maximumRecordAgeInSeconds: Input<number>`

Inherited from maximumRecordAgeInSeconds

Discard records older than this age in seconds. Use -1 for infinite. Maximum: 604800.

`maximumRetryAttempts: Input<number>`

Inherited from maximumRetryAttempts

Maximum number of retry attempts before discarding a record. Use -1 for infinite. Maximum: 10000.

`onPartialBatchItemFailure: Input<string>`

Inherited from onPartialBatchItemFailure

Partial batch failure handling strategy. Valid values: AUTOMATIC_BISECT.

`parallelizationFactor: Input<number>`

Inherited from parallelizationFactor

Number of batches to process concurrently from each shard. Maximum value: 10.

`startingPosition: Input<'TRIM_HORIZON' | 'LATEST' | 'AT_TIMESTAMP'>`

Starting position in the stream. Valid values: TRIM_HORIZON, LATEST, AT_TIMESTAMP. Triggers replacement.

`startingPositionTimestamp: Input<string>`

Unix timestamp (seconds) from which to start reading when startingPosition is AT_TIMESTAMP. Triggers replacement.