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
input {
nsq {
nsqlookupd => ["127.0.0.1:4161","1.2.3.4:4161"]
topic => "testtopic"
channel => "testchannel"
max_in_flight => 200
}
}
- nsq-ruby