Loading src/main/java/io/confluent/connect/elasticsearch/ElasticsearchSinkConnectorConfig.java +2 −1 Original line number Diff line number Diff line Loading @@ -78,7 +78,8 @@ public class ElasticsearchSinkConnectorConfig extends AbstractConfig { + "If the retry attempts are exhausted the task will fail.", group, ++order, Width.SHORT, "Max Retries") .define(RETRY_BACKOFF_MS_CONFIG, Type.LONG, 100L, Importance.LOW, "How long to wait in milliseconds before attempting to retry a failed indexing request. " "How long to wait in milliseconds before attempting the first retry of a failed indexing request. " + "Upon a failure, this connector may wait up to twice as long as the previous wait, up to the maximum number of retries. " + "This avoids retrying in a tight loop under failure scenarios.", group, ++order, Width.SHORT, "Retry Backoff (ms)"); } Loading Loading
src/main/java/io/confluent/connect/elasticsearch/ElasticsearchSinkConnectorConfig.java +2 −1 Original line number Diff line number Diff line Loading @@ -78,7 +78,8 @@ public class ElasticsearchSinkConnectorConfig extends AbstractConfig { + "If the retry attempts are exhausted the task will fail.", group, ++order, Width.SHORT, "Max Retries") .define(RETRY_BACKOFF_MS_CONFIG, Type.LONG, 100L, Importance.LOW, "How long to wait in milliseconds before attempting to retry a failed indexing request. " "How long to wait in milliseconds before attempting the first retry of a failed indexing request. " + "Upon a failure, this connector may wait up to twice as long as the previous wait, up to the maximum number of retries. " + "This avoids retrying in a tight loop under failure scenarios.", group, ++order, Width.SHORT, "Retry Backoff (ms)"); } Loading