A fluentd filter plugin for splitting messages by a customizable delimiter.

  {"message": "abc,def,ghi"}

.. is turned into ..

  {"message": "abc"}
  {"message": "def"}
  {"message": "ghi"}

Install the plugin:

# See https://github.com/BitPatty/fluent-plugin-filter-split-message/releases for a list of valid versions
gem install fluent-plugin-filter-split-message --version "<desired version>"

Create a logdrain and update your fluent configuration:

<filter>
  @type split_message

  # (Optional) The delimiter to use, defaults to ","
  delimiter ,

  # (Optional) The target field, defaults to "message"
  field_key message
</source>

• fluent-plugin-split-event used as plugin reference