Added safeguards in case the topic is not found in the registry... I may revert this because it seems this is not the right place to add this check.
Added a safeguard to filter out invalid topics BEFORE the job starts. Will need to be refactored in a cleaner, more general, way though.