this would persist kafka traffic to database to make it available long term and at high speed :)