How to terminate LFAs in Logstash and create consolidated streams into SCALA