removed kafka dependency (for now) and added logging