compressor_create

in lib/fluent/plugin/kinesis.rb [120:130]


      def compressor_create
        case @compression
        when "zlib"
          ->(data) { Zlib::Deflate.deflate(data) }
        when "gzip"
          ->(data) { Gzip.compress(data) }
        else
          ->(data) { data }
        end
      end