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: