Contents

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

<match sample.**>
    @type kafka2

    brokers "broker:29092"

    # Writes to topic `events.sample.hello.world`
    topic "events.${tag}"

    # Writes to topic `hello.world`
    # topic "${tag[1]}.${tag[2]}"

    <format>
        @type json
    </format>

    <buffer tag>
      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/dynamic_topic_based_on_tag.conf
fluent-plugin-kafka-0.19.2	examples/out_kafka2/dynamic_topic_based_on_tag.conf
fluent-plugin-kafka-0.19.1	examples/out_kafka2/dynamic_topic_based_on_tag.conf
fluent-plugin-kafka-0.19.0	examples/out_kafka2/dynamic_topic_based_on_tag.conf