initial implementation of moreover collectors in storm and storm wrapper around kafka persist writer