Read from kinesis stream

read_kinesis.sh

#!/bin/bash

stream_name=$1
while :
do
  shardIds=$(aws kinesis describe-stream --stream-name $stream_name | jq '.StreamDescription.Shards[].ShardId' | tr -d '"')

  for shard in $shardIds;do
    iterator=$(aws kinesis get-shard-iterator --stream-name $stream_name --shard-id $shard --shard-iterator-type LATEST | jq '.ShardIterator' | tr -d '"')

    data=$(aws kinesis get-records --shard-iterator "$iterator" | jq ".Records[].Data" | tr -d '""')
    for dat in $data; do
      echo $dat  | base64 -d

    done

  done

  echo "Press [CTRL+C] to stop.."
  sleep 1
done

To run this script you need to have the aws cli and jq installed