[DMAAP] Refactor dmaap jobs