Your Kinesis streams is collecting data and you need a simple and fast way to access those data for testing purpose or a custom processing. You can achieve this in 3 steps:
- Get the shard id.
- Get the shard iterator.
- Get the records.
Follow those steps in any programming language supported by AWS API. Here’s an example written in Python:
For more advanced processing, consider using the Kinesis Client Library.