key

in lib/fluent/plugin/kinesis_helper/format.rb [43:52]


      def key(record)
        if @partition_key.nil?
          SecureRandom.hex(16)
        elsif !record.key?(@partition_key)
          raise KeyNotFoundError.new(@partition_key, record)
        else
          record[@partition_key]
        end
      end