Skip to content

Commit

Permalink
Change timestamp to number
Browse files Browse the repository at this point in the history
  • Loading branch information
msambol committed Mar 28, 2024
1 parent 89b108b commit cbf852d
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 6 deletions.
7 changes: 5 additions & 2 deletions packages/@aws-cdk/aws-pipes-sources-alpha/lib/kinesis.ts
Original file line number Diff line number Diff line change
Expand Up @@ -87,11 +87,14 @@ export interface KinesisSourceParameters {

/**
* With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.
*
* @example
* 1711576897
*
* @see https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-startingpositiontimestamp
* @default - no starting position timestamp
*/
readonly startingPositionTimestamp?: string;
readonly startingPositionTimestamp?: number;
}

/**
Expand Down Expand Up @@ -168,7 +171,7 @@ export class KinesisSource implements ISource {
onPartialBatchItemFailure: this.sourceParameters.onPartialBatchItemFailure,
parallelizationFactor: this.sourceParameters.parallelizationFactor,
startingPosition: this.sourceParameters.startingPosition,
startingPositionTimestamp: this.sourceParameters.startingPositionTimestamp,
startingPositionTimestamp: this.sourceParameters.startingPositionTimestamp?.toString(),
},
},
};
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,7 @@ const sourceUnderTest = new KinesisSource(sourceKinesisStream, {
onPartialBatchItemFailure: OnPartialBatchItemFailure.AUTOMATIC_BISECT,
parallelizationFactor: 1,
startingPosition: KinesisStartingPosition.LATEST,
startingPositionTimestamp: 1711576897,
});

new Pipe(stack, 'Pipe', {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ describe('kinesis source', () => {
onPartialBatchItemFailure: OnPartialBatchItemFailure.AUTOMATIC_BISECT,
parallelizationFactor: 10,
startingPosition: KinesisStartingPosition.LATEST,
startingPositionTimestamp: 'MyTimestamp',
startingPositionTimestamp: 1711576897,
});

new Pipe(stack, 'MyPipe', {
Expand Down Expand Up @@ -87,7 +87,7 @@ describe('kinesis source', () => {
OnPartialBatchItemFailure: 'AUTOMATIC_BISECT',
ParallelizationFactor: 10,
StartingPosition: 'LATEST',
StartingPositionTimestamp: 'MyTimestamp',
StartingPositionTimestamp: '1711576897',
},
},
});
Expand All @@ -108,7 +108,7 @@ describe('kinesis source', () => {
onPartialBatchItemFailure: OnPartialBatchItemFailure.AUTOMATIC_BISECT,
parallelizationFactor: 10,
startingPosition: KinesisStartingPosition.LATEST,
startingPositionTimestamp: 'MyTimestamp',
startingPositionTimestamp: 1711576897,
});

new Pipe(stack, 'MyPipe', {
Expand Down Expand Up @@ -144,7 +144,7 @@ describe('kinesis source', () => {
OnPartialBatchItemFailure: 'AUTOMATIC_BISECT',
ParallelizationFactor: 10,
StartingPosition: 'LATEST',
StartingPositionTimestamp: 'MyTimestamp',
StartingPositionTimestamp: '1711576897',
},
},
});
Expand Down

0 comments on commit cbf852d

Please sign in to comment.