in src/fluent-plugin-mdsd/lib/fluent/plugin/out_mdsd.rb [69:76]
def format(tag, time, record)
if use_source_timestamp
[tag, time, record].to_msgpack
else
[tag, record].to_msgpack
end
end