realtime distributed message processing at scale - View it on GitHub