Dump the contents of a kinesis stream into the console

dump_stream.rb

require 'aws-sdk'

def dump_stream
    kinesis = Aws::Kinesis::Client.new(region: 'eu-west-1')

    iterator = kinesis.get_shard_iterator({
        stream_name: "testStream", 
        shard_id: "shardId-000000000000", 
        shard_iterator_type: "LATEST", 
    })

    i = iterator.shard_iterator

    while(true) do
      s = kinesis.get_records({shard_iterator: i})
      i = s.next_shard_iterator

      #puts "#{i}: #{s.records.length}"

      s.records.each { |r| puts r.data }
    end
end