a flume-like persisted append-only log implementation - View it on GitHub