in src/main/java/software/amazon/event/kafkaconnector/EventBridgeSinkConfigValidator.java [137:145]
private static void validateClassExists(ConfigValue configValue) {
var mapperClass = (String) configValue.value();
try {
Class.forName(mapperClass);
} catch (ClassNotFoundException e) {
throw new ConfigException(
mapperClass + " can't be loaded. Ensure the class path you have specified is correct.");
}
}