enum KinesisStartingPosition
Language | Type name |
---|---|
![]() | Amazon.CDK.AWS.Pipes.Sources.Alpha.KinesisStartingPosition |
![]() | github.com/aws/aws-cdk-go/awscdkpipessourcesalpha/v2#KinesisStartingPosition |
![]() | software.amazon.awscdk.services.pipes.sources.alpha.KinesisStartingPosition |
![]() | aws_cdk.aws_pipes_sources_alpha.KinesisStartingPosition |
![]() | @aws-cdk/aws-pipes-sources-alpha ยป KinesisStartingPosition |
The position in a Kinesis stream from which to start reading.
Example
declare const sourceStream: kinesis.Stream;
declare const targetQueue: sqs.Queue;
const pipeSource = new sources.KinesisSource(sourceStream, {
startingPosition: sources.KinesisStartingPosition.LATEST,
});
const pipe = new pipes.Pipe(this, 'Pipe', {
source: pipeSource,
target: new SqsTarget(targetQueue)
});
Members
Name | Description |
---|---|
TRIM_HORIZON | Start streaming at the last untrimmed record in the shard, which is the oldest data record in the shard. |
LATEST | Start streaming just after the most recent record in the shard, so that you always read the most recent data in the shard. |
AT_TIMESTAMP | Start streaming from the position denoted by the time stamp specified in the startingPositionTimestamp field. |
TRIM_HORIZON
Start streaming at the last untrimmed record in the shard, which is the oldest data record in the shard.
LATEST
Start streaming just after the most recent record in the shard, so that you always read the most recent data in the shard.
AT_TIMESTAMP
Start streaming from the position denoted by the time stamp specified in the startingPositionTimestamp
field.