nats streaming plugin for fluentd Event Collector
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>
localhost:4222
fluentd
fluentd
fluentd
fluentd