key_formatter_create

in lib/fluent/plugin/out_kinesis_streams.rb [57:69]

• 12 lines of code
• 3 McCabe index (conditional complexity)

      def key_formatter_create
        if @partition_key.nil?
          ->(record) { SecureRandom.hex(16) }
        else
          ->(record) {
            if !record.key?(@partition_key)
              raise KeyNotFoundError.new(@partition_key, record)
            end
            record[@partition_key]
          }
        end
      end