master
emitEvent
async emitEvent(eventName, data) { this._logger.debug( `Creating event ${eventName} in kafka if it does not already exist.` ); try {