|
24 | 24 | import java.util.Objects; |
25 | 25 | import java.util.stream.Collectors; |
26 | 26 |
|
| 27 | +import io.aiven.kafka.connect.common.config.validators.TimeScaleValidator; |
27 | 28 | import org.apache.kafka.common.config.ConfigDef; |
28 | 29 | import org.apache.kafka.common.config.ConfigException; |
29 | 30 | import org.apache.kafka.common.config.ConfigValue; |
@@ -182,13 +183,13 @@ public static Setter setter(final Map<String, String> configData) { |
182 | 183 | static void addS3RetryPolicies(final ConfigDef configDef) { |
183 | 184 | var retryPolicyGroupCounter = 0; |
184 | 185 | configDef.define(AWS_S3_RETRY_BACKOFF_DELAY_MS_CONFIG, ConfigDef.Type.LONG, |
185 | | - AWS_S3_RETRY_BACKOFF_DELAY_MS_DEFAULT, ConfigDef.Range.atLeast(1L), ConfigDef.Importance.MEDIUM, |
| 186 | + AWS_S3_RETRY_BACKOFF_DELAY_MS_DEFAULT, TimeScaleValidator.atLeast(1), ConfigDef.Importance.MEDIUM, |
186 | 187 | "S3 default base sleep time for non-throttled exceptions in milliseconds. " + "Default is " |
187 | 188 | + AWS_S3_RETRY_BACKOFF_DELAY_MS_DEFAULT + ".", |
188 | 189 | GROUP_S3_RETRY_BACKOFF_POLICY, ++retryPolicyGroupCounter, ConfigDef.Width.NONE, |
189 | 190 | AWS_S3_RETRY_BACKOFF_DELAY_MS_CONFIG); |
190 | 191 | configDef.define(AWS_S3_RETRY_BACKOFF_MAX_DELAY_MS_CONFIG, ConfigDef.Type.LONG, |
191 | | - AWS_S3_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT, ConfigDef.Range.atLeast(1L), ConfigDef.Importance.MEDIUM, |
| 192 | + AWS_S3_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT, TimeScaleValidator.atLeast(1), ConfigDef.Importance.MEDIUM, |
192 | 193 | "S3 maximum back-off time before retrying a request in milliseconds. " + "Default is " |
193 | 194 | + AWS_S3_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT + ".", |
194 | 195 | GROUP_S3_RETRY_BACKOFF_POLICY, ++retryPolicyGroupCounter, ConfigDef.Width.NONE, |
|
0 commit comments