private static void defineErrorHandlingAndRetriesConfigs()

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);
    }