Handle AvroRuntimeException to avoid validation request failed with 500 status code

Author: kapilchhajer

src/main/java/io/confluent/kafka/connect/datagen/ConfigUtils.java

@@ -35,10 +35,10 @@ public static Schema getSchemaFromSchemaString(String schemaString) {
     Schema schema;
     try {
       schema = schemaParser.parse(schemaString);
-    } catch (SchemaParseException e) {
+    } catch (SchemaParseException | AvroRuntimeException e) {
       log.error("Unable to parse the provided schema", e);
       throw new ConfigException("Unable to parse the provided schema");
-    }
+
     return schema;
   }
 
@@ -56,11 +56,11 @@ public static Schema getSchemaFromSchemaFileName(String schemaFileName) {
         schema = schemaParser.parse(
           DatagenTask.class.getClassLoader().getResourceAsStream(schemaFileName)
         );
-      } catch (SchemaParseException | IOException i) {
+      } catch (SchemaParseException | AvroRuntimeException | IOException i) {
         log.error("Unable to parse the provided schema", i);
         throw new ConfigException("Unable to parse the provided schema");
       }
-    } catch (SchemaParseException | IOException e) {
+    } catch (SchemaParseException | AvroRuntimeException | IOException e) {
       log.error("Unable to parse the provided schema", e);
       throw new ConfigException("Unable to parse the provided schema");
     }