fluent-plugin-nng

Fluentd input and output plugin for Nano Msg.

Installation

You can install this gem using the following command:

$ fluent-gem install fluent-plugin-nng

Configuration

Example for input plugin

This example creates a listening nanomsg socket, reads data from it and parses the data using the fluentd-plugin fluent-plugin-parser-protobuf:

<source>
  @type nng
  @id input_nng
  <parse>
    @type protobuf
    class_file /opt/schemas_pb.rb
    class_name LogSchema
    protobuf_version protobuf3
  </parse>
  uri tcp://127.0.0.1:5557
  tag nng.*
</source>

<match nng.**>
  @type stdout
</match>

Example for output and formatter plugin

This example reads logs from a file(/var/log/some.log) and sends the data to a nano msg socket. It automatically formats the data using the detectmate LogSchema using fluent-plugin-detectmate. 

<source>
  @type tail
  @id input_tail
  <parse>
    @type none
  </parse>
  path /var/log/some.log
  path_key logSource

  tag nng.*
</source>

<match nng.**>
  @type nng
  uri tcp://127.0.0.1:5557
  <inject>
    hostname_key hostname
    # overwrite hostname:
    # hostname somehost
  </inject>
  <buffer>
    flush_mode immediate
  </buffer>
  <format>
    @type detectmate
  </format>
</match>

Limitations

Currently only PAIR communication for nng is supported.

  • Copyright(c) 2026- whotwagner
  • License
    • EUROPEAN UNION PUBLIC LICENCE, Version 1.2