Low latency high throughput aggregator for real time streams - View it on GitHub