fluent/fluentd

<source>
  @type sample
  @label @main
  tag "test.data"
  size 2
  rate 10
  sample {"message":"yaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaay"}
  auto_increment_key number
</source>

<label @main>
  <match test.data>
    @type stdout
    <buffer>
      @type file
      path "#{Dir.pwd}/compressed_buffers"
      flush_at_shutdown false
      chunk_limit_size 1m
      flush_interval 10s
      compress gzip
    </buffer>
  </match>
</label>