One line to get all records from a stream since its StartingSequenceNumber
. Just specify the shard
, endpoint
, and stream
at the start of the script.
shard="shardId-000000000001"; endpoint="http://localhost:4567"; stream="test-stream";
See here an example pointed at kinesalite
running locally.
shard="shardId-000000000001"; endpoint="http://localhost:4567"; stream="test-stream"; \