Core library for Hadoop aggregators and Kafka processors. - View it on GitHub