in src/main/java/software/amazon/event/kafkaconnector/EventBridgeSinkConfigValidator.java [44:128]
public static void validate(ConfigValue configValue, EnvVarGetter getenv) {
switch (configValue.name()) {
case AWS_CONNECTOR_ID_CONFIG:
{
validateConnectorId(configValue);
break;
}
case AWS_ENDPOINT_URI_CONFIG:
{
validateURI(configValue);
break;
}
case AWS_EVENTBUS_ARN_CONFIG:
{
validateBusArn(configValue);
break;
}
case AWS_RETRIES_CONFIG:
{
validateEventBusRetries(configValue);
break;
}
case AWS_CREDENTIAL_PROVIDER_CLASS:
{
validateAwsCredentialProviderClass(configValue);
break;
}
case AWS_ROLE_ARN_CONFIG:
{
validateRoleArn(configValue);
break;
}
case AWS_REGION_CONFIG:
{
validateRegion(configValue);
break;
}
case AWS_DETAIL_TYPES_CONFIG:
{
validateDetailType(configValue);
break;
}
case AWS_EVENTBUS_GLOBAL_ENDPOINT_ID_CONFIG:
{
validateEndpointId(configValue);
break;
}
case AWS_PROFILE_NAME_CONFIG:
{
validateProfileName(configValue, getenv);
break;
}
case AWS_DETAIL_TYPES_MAPPER_CLASS:
{
validateClassExists(configValue);
break;
}
case AWS_TIME_MAPPER_CLASS:
{
validateClassExists(configValue);
break;
}
case AWS_OFFLOADING_DEFAULT_S3_ENDPOINT_URI:
{
validateURI(configValue);
break;
}
case AWS_OFFLOADING_DEFAULT_S3_BUCKET:
{
nonStrictValidateOffloadingDefaultS3Bucket(configValue);
break;
}
case AWS_OFFLOADING_DEFAULT_FIELDREF:
{
validateOffloadingDefaultFieldRef(configValue);
break;
}
}
}