add test record schema validation error

Author: alovew

airbyte-workers/src/main/java/io/airbyte/workers/RecordSchemaValidator.java

@@ -71,6 +71,13 @@ public void validateSchema(final AirbyteRecordMessage message, final String mess
       throw new RecordSchemaValidationException(validationMessagesToDisplay,
           String.format("Record schema validation failed for %s", messageStream));
     }
-  }
 
+    if(messageStream == "pokemon"){
+      final Set<String> validationMessagesToDisplay = new HashSet<>();
+      validationMessagesToDisplay.add("test validation error message");
+
+      throw new RecordSchemaValidationException(validationMessagesToDisplay,
+          String.format("Record schema validation failed for %s", messageStream));
+    }
+  }
 }