diff --git a/fluentd/lib/fluent-plugin-remote_syslog/lib/fluent/plugin/out_remote_syslog.rb b/fluentd/lib/fluent-plugin-remote_syslog/lib/fluent/plugin/out_remote_syslog.rb index d0f97b7893..528ea5ac6f 100644 --- a/fluentd/lib/fluent-plugin-remote_syslog/lib/fluent/plugin/out_remote_syslog.rb +++ b/fluentd/lib/fluent-plugin-remote_syslog/lib/fluent/plugin/out_remote_syslog.rb @@ -78,8 +78,9 @@ def close end def format(tag, time, record) + require 'json' r = inject_values_to_record(tag, time, record) - @formatter.format(tag, time, r) + r.to_json << "\n" end def write(chunk)