in lib/fluent/plugin/kinesis_helper/api.rb [127:143]
def collect_failed_records(records, res)
failed_records = []
results(res).each_with_index do |record, index|
next unless record[:error_code]
original = case request_type
when :streams, :firehose; records[index]
when :streams_aggregated; records
end
failed_records.push(
original: original,
error_code: record[:error_code],
error_message: record[:error_message]
)
end
failed_records
end