This codec handles fluentd’s msgpack schema.

For example, you can receive logs from fluent-logger-ruby with:

    input {
      tcp {
        codec => fluent
        port => 4000

And from your ruby code in your own application:

    logger = Fluent::Logger::FluentLogger.new(nil, :host => "example.log", :port => 4000)
    logger.post("some_tag", { "your" => "data", "here" => "yay!" })


  • the fluent uses a second-precision time for events, so you will never see subsecond precision on events processed by this codec.



This plugin has no configuration options.

Complete configuration example:

fluent {