kinesis-consume.js

var AWS = require("aws-sdk");

AWS.config.loadFromPath("./config.json");
var kinesis = new AWS.Kinesis();

kinesis.describeStream({
  StreamName: "rch850-stream"
}, function(err, data) {
  var startingSequenceNumber = data.StreamDescription.Shards[0].SequenceNumberRange.StartingSequenceNumber;

  kinesis.getShardIterator({
    StreamName: "rch850-stream",
    ShardId: data.StreamDescription.Shards[0].ShardId",
    ShardIteratorType: "LATEST"
  }, function(err, data) {
    if (err) {
      console.log(err, err.stack);
      return;
    }
    console.log(data);

    kinesis.getRecords({
      Limit: 10,
      ShardIterator: data.ShardIterator
    }, function(err, data) {
      if (err) {
        console.log(err, err.stack);
        return;
      }
      console.log(data);
    });
  });
});