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 {