give_up_retries

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