Stream From Kinesis

StreamFromKinesis.js

var AWS = require("aws-sdk")
var options =
  { endPoint: "https://kinesis.ap-southeast-1.amazonaws.com"
  , accessKeyId: ""
  , secretAccessKey: ""
  , region: "ap-southeast-1"
  }
var request4 = new AWS.Kinesis(options).subscribeToShard(
  { "ConsumerARN": ""
    , "ShardId": "shardId-"
    , "StartingPosition": {Type: "LATEST"}
  })
request4.
on('httpHeaders', function(st, headers, resp, statusMsg){
  console.log(st);
  console.log(headers);
}).
on('httpData', function(chunk, response){
  console.log("-----------------------------------------------------------")
  console.log(chunk.toString('ascii'));
}).
send();