An extensible distributed system for reliable nearline data streaming at scale - View it on GitHub