alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5045 Remove deprecated OBSOLETE_NAME_FOR_SKIP_FAILURE_HANDLING option value

Browse Source
This commit is contained in:
Vojtech Juranek 2022-06-07 12:41:35 +02:00 committed by Jiri Pechanec
parent 76c8550e7b
commit ef8d7f7af7
2 changed files with 0 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlConnectorConfig.java
View File

@ -841,7 +841,6 @@ public static SecureConnectionMode parse(String value, String defaultValue) {
.withDisplayName("Inconsistent schema failure handling")
.withEnum(EventProcessingFailureHandlingMode.class, EventProcessingFailureHandlingMode.FAIL)
.withGroup(Field.createGroupEntry(Field.Group.ADVANCED, 2))
.withValidation(MySqlConnectorConfig::validateInconsistentSchemaHandlingModeNotIgnore)
.withWidth(Width.SHORT)
.withImportance(Importance.MEDIUM)
.withDescription(
@ -1011,23 +1010,6 @@ private static int validateEventDeserializationFailureHandlingModeNotSet(Configu
if (modeName != null) {
LOGGER.warn("Configuration option '{}' is renamed to '{}'", EVENT_DESERIALIZATION_FAILURE_HANDLING_MODE.name(),
EVENT_PROCESSING_FAILURE_HANDLING_MODE.name());
if (EventProcessingFailureHandlingMode.OBSOLETE_NAME_FOR_SKIP_FAILURE_HANDLING.equals(modeName)) {
LOGGER.warn("Value '{}' of configuration option '{}' is deprecated and should be replaced with '{}'",
EventProcessingFailureHandlingMode.OBSOLETE_NAME_FOR_SKIP_FAILURE_HANDLING,
EVENT_DESERIALIZATION_FAILURE_HANDLING_MODE.name(),
EventProcessingFailureHandlingMode.SKIP.getValue());
}
}
return 0;
}
private static int validateInconsistentSchemaHandlingModeNotIgnore(Configuration config, Field field, ValidationOutput problems) {
final String modeName = config.getString(INCONSISTENT_SCHEMA_HANDLING_MODE);
if (EventProcessingFailureHandlingMode.OBSOLETE_NAME_FOR_SKIP_FAILURE_HANDLING.equals(modeName)) {
LOGGER.warn("Value '{}' of configuration option '{}' is deprecated and should be replaced with '{}'",
EventProcessingFailureHandlingMode.OBSOLETE_NAME_FOR_SKIP_FAILURE_HANDLING,
INCONSISTENT_SCHEMA_HANDLING_MODE.name(),
EventProcessingFailureHandlingMode.SKIP.getValue());
}
return 0;
}

7
debezium-core/src/main/java/io/debezium/config/CommonConnectorConfig.java
View File

@ -134,8 +134,6 @@ public enum EventProcessingFailureHandlingMode implements EnumeratedValue {
*/
IGNORE("ignore");
public static final String OBSOLETE_NAME_FOR_SKIP_FAILURE_HANDLING = "ignore";
private final String value;
EventProcessingFailureHandlingMode(String value) {
@ -160,11 +158,6 @@ public static EventProcessingFailureHandlingMode parse(String value) {
value = value.trim();
// backward compatibility, will be removed in 1.2
if (OBSOLETE_NAME_FOR_SKIP_FAILURE_HANDLING.equals(value)) {
return SKIP;
}
for (EventProcessingFailureHandlingMode option : EventProcessingFailureHandlingMode.values()) {
if (option.getValue().equalsIgnoreCase(value)) {
return option;