Reads messages from Kafka topic and writes them to HDFS, Cassandra and Elastic Search, runs a parallel thread that counts amount of saved records in each destination
Reads messages from Kafka topic on Shipped Central cluster (containing information about CPU/RAM utilization of different hosts) and writes alerts to Elastic Search if any of these metrics are beyond given thresholds