Identifying Kinesis stream pending message count

Question

Is there an API that gives pending messages for Kinesis stream.

After a period of 7 days the messages expire and if the producers and consumers are isolated and can't communicate, how does one know messages have expired. How does one deal with?

Answer 1

Please help!

I doubt there is a thing called as pending messages in Kinesis. Now we have a shard in Kinesis where all the incoming stream gets stored.

Your consumer application has to always be in running state and keep track of changes in your stream. The application will continue to poll "Shard Iterator" in the background, thus you will be notified about the new data when it comes.

Think of Kinesis as a FIFO queue and the messages will disappear in a short time if you don't pop them.

I hope this helps.