Create a gist now

Instantly share code, notes, and snippets.

What would you like to do?
example of logstash load balanced indexers with zeromq


In this example these are using a zeromq input with ZMQ::PULL as the socket type

I started four logstash agents with this config

input {
zeromq { format => "json_event" socket_type => "pull" type => "pull-test-input" }
output { stdout { debug => true } }


This is using zeromq output with ZMQ::PUSH as the socket type. I started one of these

input { stdin { debug => "true" type => "stdin-input-test"} }
output { zeromq { socket_type => "push"}}



Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment