diff --git a/debezium-core/src/main/java/io/debezium/config/CommonConnectorConfig.java b/debezium-core/src/main/java/io/debezium/config/CommonConnectorConfig.java index 49fa47d1a..c8673f286 100644 --- a/debezium-core/src/main/java/io/debezium/config/CommonConnectorConfig.java +++ b/debezium-core/src/main/java/io/debezium/config/CommonConnectorConfig.java @@ -844,12 +844,15 @@ public static EventConvertingFailureHandlingMode parse(String value) { + "'insert_delete' only open signal is written on signal data collection, the close will delete the relative open signal;"); public static final Field EVENT_CONVERTING_FAILURE_HANDLING_MODE = Field.create("event.converting.failure.handling.mode") - .withDisplayName("Event deserialization failure handling") + .withDisplayName("Event converting failure handling") .withGroup(Field.createGroupEntry(Field.Group.CONNECTOR_ADVANCED, 26)) .withEnum(EventConvertingFailureHandlingMode.class, EventConvertingFailureHandlingMode.WARN) .withWidth(Width.SHORT) .withImportance(Importance.MEDIUM) - .withDescription("TODO"); + .withDescription("Specify how failures during converting of event should be handled, including: " + + "'fail' throw an exception that the column of event conversion is failed with unmatched schema type, causing the connector to be stopped. it needs schema recovery to covert successfully; " + + "'warn' (the default) the value of column of event that conversion failed will be null and be logged with warn level; " + + "'skip' the value of column of event that conversion failed will be null and be logged with debug level."); protected static final ConfigDefinition CONFIG_DEFINITION = ConfigDefinition.editor() .connector(