diff --git a/lib/fluent/plugin/output.rb b/lib/fluent/plugin/output.rb index 1bffc24460..28dd3f8d2d 100644 --- a/lib/fluent/plugin/output.rb +++ b/lib/fluent/plugin/output.rb @@ -377,6 +377,7 @@ def configure(conf) buffer_conf = conf.elements(name: 'buffer').first || Fluent::Config::Element.new('buffer', '', {}, []) @buffer = Plugin.new_buffer(buffer_type, parent: self) @buffer.configure(buffer_conf) + keep_buffer_config_compat @buffer.enable_update_timekeys if @chunk_key_time @flush_at_shutdown = @buffer_config.flush_at_shutdown @@ -434,6 +435,12 @@ def configure(conf) self end + def keep_buffer_config_compat + # Need this to call `@buffer_config.disable_chunk_backup` just as before, + # since some plugins may use this option in this shape. + @buffer_config[:disable_chunk_backup] = @buffer.disable_chunk_backup + end + def start super