in src/main/java/software/amazon/event/kafkaconnector/mapping/DefaultEventBridgeMapper.java [81:90]
private TimeMapper getTimeMapper(EventBridgeSinkConfig config) {
try {
var myClass = Class.forName(config.timeMapperClass);
var constructor = myClass.getDeclaredConstructor();
return (TimeMapper) constructor.newInstance();
} catch (Exception e) {
// This will already be verified in the Config Validator
throw new RuntimeException("Time Mapper Class can't be loaded: ", e);
}
}