in lib/fluent/plugin/kinesis_helper/api.rb [127:136]
def give_up_retries(failed_records)
failed_records.each {|record|
log.error(truncate 'Could not put record, Error: %s/%s, Record: %s' % [
record[:error_code],
record[:error_message],
record[:original]
])
}
end