fluentd で殴り合い

fluent.conf

<source>
  type forward
  port 12345
</source>
<match **>
    type forward
    buffer_type memory
    buffer_chunk_limit 4m
    buffer_queue_limit 128
    flush_interval 1s
    <server>
        host localhost
        port 12346
    </server>
</match>

fluent2.conf

<source>
  type forward
  port 12346
</source>
<match **>
    type forward
    buffer_type memory
    buffer_chunk_limit 4m
    buffer_queue_limit 128
    flush_interval 1s
    <server>
        host localhost
        port 12345
    </server>
</match>

kick.py

import msgpack
import subprocess

data = msgpack.packb({"foo": "a"*10000})
proc = subprocess.Popen('fluent-cat -p12345 --msgpack foo.bar', shell=True, stdin=subprocess.PIPE)
proc.stdin.write(data*10000)
proc.stdin.close()