I have an architecture where lambda function delivers the events in a kinesis stream to a client. If the event is successfully delivered then the the event should be popped off of the queue in the kinesis stream. If the event was not successfully delivered, then it will try again in x number of minutes.

1. How to determine if the event was successfully delivered?
2. How to manually pop an event off the data stream queue?
3. How to schedule a re run if unsuccessful?

CodePudding user response：

I think you are confusing SQS with Kinesis. Kinesis does not have any "queues" nor you can't "pop" any messages from Kinesis. You have to wait till they expire themselves.

Also you have no control over what and if the clients read messages from the Kinesis stream. Its client responsibility to manage that, not you as a producer.