I’m using Kinesis to stream messages that are coming from other services. Now I need a new functionality to replay those messages in case of any failure or any eventuality.
Basically I want to replay the messages that have been retained in the retention period window that I’ve configured in my Kinesis Data Stream.
In that order I’m looking an implementation with these params:

startDate: Initial date to start to replay messages from Kinesis.
endDate: Final date to finish to search the messages to replay.

I was reading in the documentation and I found GetShardIterator functionality but it only has TimeStamp parameter which works as startDate. I’m not sure about if is possible to setup a endDate parameter in this or if might exists another library or functioanlity I can use.
Note: I want to do this directly calling the Kinesis Data Stream, I’m not looking a solution with a S3 bucket or a SQS or something like that.