Definitely seems like something to replace leveldb with vs kafka. Or maybe more akin to http://chronicle.software/products/chronicle-queue/ minus the TCP replication