feat: Add compression level configuration to ZstdCompressor

Signed-off-by: ddukbg <[email protected]>

lib/fluent/plugin/out_s3.rb

@@ -632,17 +632,25 @@ def compress(chunk, tmp)
     end
 
     class ZstdCompressor < Compressor
+      DEFAULT_LEVEL = 3
+
+      def initialize(level = nil)
+        @level = level || DEFAULT_LEVEL
+      end
+
       def ext
         'zst'.freeze
       end
-
+    
       def content_type
         'application/x-zst'.freeze
       end
-
+    
       def compress(chunk, tmp)
-        compressed_data = Zstd.compress(chunk.read, level: @level)
+        data = chunk.read
+        compressed_data = Zstd.compress(data, level: @level)
         tmp.write(compressed_data)
+        tmp.close
       rescue => e
         log.warn "zstd compression failed: #{e.message}"
         raise e