Contents

<source>
    @type sample
    sample {"hello": "world", "some_record":{"event":"message"}}
    rate 7000
    tag sample.hello.world
</source>

<match sample.**>
    @type kafka2

    brokers "broker:29092"

    # {"event": "message"} will be formatted and sent to Kafka
    record_key "some_record"

    default_topic "events"

    <format>
        @type json
    </format>

    <buffer>
      flush_at_shutdown true
      flush_mode interval
      flush_interval 1s
      chunk_limit_size 3MB
      chunk_full_threshold 1
      total_limit_size 1024MB
      overflow_action block
    </buffer>
</match>

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
fluent-plugin-kafka-0.19.3	examples/out_kafka2/record_key.conf
fluent-plugin-kafka-0.19.2	examples/out_kafka2/record_key.conf
fluent-plugin-kafka-0.19.1	examples/out_kafka2/record_key.conf
fluent-plugin-kafka-0.19.0	examples/out_kafka2/record_key.conf