Logstash NSQ support

mschn · June 24, 2015, 1:49pm

Hello, I just read the new Blog about Kafka integration, thats really nice!
Are there any plans to integrate support also for nsq.io ?

mschn · July 9, 2015, 5:52pm

I wrote a nsq input plugin
if you need nsq support feel free to install:
/opt/logstash/bin/plugin install logstash-input-nsq

github.com

mschneider82/logstash-input-nsq/blob/master/DEVELOPER.md

logstash-input-nsq
====================

NSQ input for Logstash. This input will consume messages from a nsq topic using nsq-ruby. 

For more information about NSQ, refer to this [documentation](http://nsq.io) 

Logstash Configuration
====================

    input {
       nsq {
            nsqlookupd => ["127.0.0.1:4161","1.2.3.4:4161"]
            topic => "testtopic"
            channel => "testchannel"
            max_in_flight  => 200
       }
    }

Dependencies

This file has been truncated. show original

mschn · July 13, 2015, 8:40am

the nsq output plugin is also ready!

/opt/logstash/bin/plugin install logstash-output-nsq

github.com

mschneider82/logstash-output-nsq/blob/master/DEVELOPER.md

logstash-output-nsq
====================

NSQ output Plugin for Logstash. This output will produce messages to a nsq topic using nsq-ruby. 

For more information about NSQ, refer to this [documentation](http://nsq.io) 

Logstash Configuration
====================

Using a static NSQD:
====================

    output {
       nsq {
            nsqd => 127.0.0.1:4150"
            topic => "testtopic"
       }
    }

This file has been truncated. show original

elvarb · October 3, 2016, 9:39am

Any plans to add this to the official plugin repos ?