Not to enable compress forcedly

fluent · Sep 1, 2016 · 1e55447 · 1e55447
1 parent 38c72a5
commit 1e55447
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/lib/fluent/plugin/out_forward.rb b/lib/fluent/plugin/out_forward.rb
@@ -136,6 +136,12 @@ def configure(conf)
         log.info "adding forwarding server '#{name}'", host: host, port: port, weight: weight, plugin_id: plugin_id
       }
 
+      if @compress == :gzip && @buffer.compress == :text
+        @buffer.compress = :gzip
+      elsif @compress == :text && @buffer.compress == :gzip
+        log.info "buffer is compressed.  If you also want to save the bandwidth of a network, Add `compress` configuration in <match>"
+      end
+
       if @nodes.empty?
         raise ConfigError, "forward output plugin requires at least one <server> is required"
       end

diff --git a/test/plugin/test_out_forward.rb b/test/plugin/test_out_forward.rb
@@ -110,7 +110,7 @@ def test_configure_gzip_compress_in_buffer
         compress gzip
       </buffer>
     ])
-    assert_equal :gzip, d.instance.compress
+    assert_equal :text, d.instance.compress
     assert_equal :gzip, d.instance.buffer.compress
   end