in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java [139:199]
private static void defineErrorHandlingAndRetriesConfigs(ConfigDef result) {
final String errorAndRetriesGroupName = "Error Handling and Retries";
int errorAndRetriesGroupOrder = 0;
result
.define(
KUSTO_BEHAVIOR_ON_ERROR_CONF,
Type.STRING,
BehaviorOnError.FAIL.name(),
ConfigDef.ValidString.in(
BehaviorOnError.FAIL.name(), BehaviorOnError.LOG.name(), BehaviorOnError.IGNORE.name(),
BehaviorOnError.FAIL.name().toLowerCase(Locale.ENGLISH), BehaviorOnError.LOG.name().toLowerCase(Locale.ENGLISH),
BehaviorOnError.IGNORE.name().toLowerCase(Locale.ENGLISH)),
Importance.LOW,
KUSTO_BEHAVIOR_ON_ERROR_DOC,
errorAndRetriesGroupName,
errorAndRetriesGroupOrder++,
Width.LONG,
KUSTO_BEHAVIOR_ON_ERROR_DISPLAY)
.define(
KUSTO_DLQ_BOOTSTRAP_SERVERS_CONF,
Type.LIST,
"",
Importance.LOW,
KUSTO_DLQ_BOOTSTRAP_SERVERS_DOC,
errorAndRetriesGroupName,
errorAndRetriesGroupOrder++,
Width.MEDIUM,
KUSTO_DLQ_BOOTSTRAP_SERVERS_DISPLAY)
.define(
KUSTO_DLQ_TOPIC_NAME_CONF,
Type.STRING,
"",
Importance.LOW,
KUSTO_DLQ_TOPIC_NAME_DOC,
errorAndRetriesGroupName,
errorAndRetriesGroupOrder++,
Width.MEDIUM,
KUSTO_DLQ_TOPIC_NAME_DISPLAY)
.define(
KUSTO_SINK_MAX_RETRY_TIME_MS_CONF,
Type.LONG,
TimeUnit.SECONDS.toMillis(300),
Importance.LOW,
KUSTO_SINK_MAX_RETRY_TIME_MS_DOC,
errorAndRetriesGroupName,
errorAndRetriesGroupOrder++,
Width.MEDIUM,
KUSTO_SINK_MAX_RETRY_TIME_MS_DISPLAY)
.define(
KUSTO_SINK_RETRY_BACKOFF_TIME_MS_CONF,
Type.LONG,
TimeUnit.SECONDS.toMillis(10),
ConfigDef.Range.atLeast(1),
Importance.LOW,
KUSTO_SINK_RETRY_BACKOFF_TIME_MS_DOC,
errorAndRetriesGroupName,
errorAndRetriesGroupOrder++,
Width.MEDIUM,
KUSTO_SINK_RETRY_BACKOFF_TIME_MS_DISPLAY);
}