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"

    record_key "some_record"
    default_topic "events"

    <format>
        # requires the fluent-plugin-formatter-protobuf gem
        # see its docs for full usage
        @type protobuf
        class_name SomeRecord
        include_paths ["/opt/fluent-plugin-formatter-protobuf/some_record_pb.rb"]
    </format>
</match>

Version data entries

4 entries across 4 versions & 1 rubygems

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