Logstash - add a streaming analytic job interface

[Alex-Ikanow]

ie uses the kafka input and output (for now would only support batch or streaming transient output, you'd need something at the end to write into the data store)