fluentd-recover.rb

require 'fluent-logger'

# specify the host and port to forward data to
logger = Fluent::Logger.new(nil, :host => "localhost", :port => 24224)

fn = ARGV[0]
fh = File.new(fn)

msgpack_unpacker = MessagePack::Unpacker.new(fh)

begin
  msgpack_unpacker.each do |time, record|
    # post data with the tag "t"
    logger.post_with_time('t', record, time)
  end
ensure
  fh.close
end