gistfile1.txt

input {
  # Sample input over UDP
  udp { format => "json" port => 9999 type => "rlog_udp" }
  redis {
    host => "10.20.7.34"
    data_type => "list"
    key => "logstash"
    codec => json
  }
}
 
output {
  elasticsearch {
    embedded => true
  }
}

filter {
  split {
    type => "rlog"
  }
}