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