in src/main/java/software/amazon/event/kafkaconnector/mapping/DefaultEventBridgeMapper.java [68:79]
private DetailTypeMapper getDetailTypeMapper(EventBridgeSinkConfig config) {
try {
var myClass = Class.forName(config.detailTypeMapperClass);
var constructor = myClass.getDeclaredConstructor();
var detailTypeMapper = (DetailTypeMapper) constructor.newInstance();
detailTypeMapper.configure(config);
return detailTypeMapper;
} catch (Exception e) {
// This will already be verified in the Config Validator
throw new RuntimeException("Topic to Detail-Type Mapper Class can't be loaded: ", e);
}
}