Consume Kinesis Stream

kinesis_stream_getRecords.js

const STREAM_NAME = 'ssullivan-kinesis-fu';
const REGION = 'us-west-2';

const AWS = require('aws-sdk');

const kinesis = new AWS.Kinesis({ region: REGION });

const getRecordsFromShard = async (streamName) => {
    const { Shards: [ { ShardId: shardId } ] } = await kinesis.listShards({ 'StreamName': streamName }).promise();

    const { ShardIterator: shardIterator } = await kinesis.getShardIterator({
        ShardId: shardId,
        ShardIteratorType: 'TRIM_HORIZON',
        StreamName: streamName
    }).promise();

    return await kinesis.getRecords({
        ShardIterator: shardIterator,
        Limit: 10
    }).promise();
};

getRecordsFromShard(STREAM_NAME)
    .then(result => {
        console.log(result);
        process.exit(1);
    });