No commit activity in last 3 years
No release in over 3 years
nats streaming plugin for fluentd, an event collector
2005
2006
2007
2008
2009
2010
2011
2012
2013
2014
2015
2016
2017
2018
2019
2020
2021
2022
2023
2024
 Dependencies

Development

~> 0.9, >= 0.9.2
~> 0.3, > 3.1

Runtime

>= 0.14.20, < 2
~> 0.2, >= 0.2.2
 Project Readme

fluent-plugin-nats-streaming

nats streaming plugin for fluentd Event Collector

Getting Started

example for nats streaming input:

  <system>
    workers 2
  </system>

  <source>
    @type nats-streaming
    server "127.0.0.1:4222,127.0.0.1:4223,127.0.0.1:4224"
    cluster_id test-cluster

    client_id "in-#{Socket.gethostname}-#{worker_id}"
    channel   nats.test
    queue     test
  </source>
 
  <match nats.test>
    @type stdout
  </match>

example for nats streaming output:

  <system>
    workers 2
  </system>

  <match nats.**>
    @type nats-streaming
    server "127.0.0.1:4222,127.0.0.1:4223,127.0.0.1:4224"
    client_id "out-#{Socket.gethostname}-#{worker_id}"
    cluster_id test-cluster

    <format>
      @type json
    </format>
  </match>

Configuration

  • server (string) (optional): NATS streaming server host:port
    • Default value: localhost:4222
  • cluster_id (string) (optional): cluster id
    • Default value: fluentd
  • client_id (string) (optional): client id
    • Default value: fluentd
  • durable_name (string) (optional): durable name
    • Default value: fluentd
  • queue (string) (optional): queue name
    • Default value: fluentd
  • channel (string) : channel name
    • Default value: nil
  • max_reconnect_attempts (integer) : The max number of reconnect tries
    • Default value: 10
  • reconnect_time_wait (integer) : The number of seconds to wait between reconnect tries
    • Default value: 5
  • timeout (integer) : Ack timeout when publish
    • Default value: 5