Package | Description |
---|---|
org.apache.storm.kafka.spout |
Modifier and Type | Method and Description |
---|---|
static KafkaSpoutRetryExponentialBackoff.TimeInterval |
KafkaSpoutRetryExponentialBackoff.TimeInterval.microSeconds(long length) |
static KafkaSpoutRetryExponentialBackoff.TimeInterval |
KafkaSpoutRetryExponentialBackoff.TimeInterval.milliSeconds(long length) |
static KafkaSpoutRetryExponentialBackoff.TimeInterval |
KafkaSpoutRetryExponentialBackoff.TimeInterval.seconds(long length) |
Constructor and Description |
---|
KafkaSpoutRetryExponentialBackoff(KafkaSpoutRetryExponentialBackoff.TimeInterval initialDelay,
KafkaSpoutRetryExponentialBackoff.TimeInterval delayPeriod,
int maxRetries,
KafkaSpoutRetryExponentialBackoff.TimeInterval maxDelay)
The time stamp of the next retry is scheduled according to the exponential backoff formula (geometric progression):
nextRetry = failCount == 1 ? currentTime + initialDelay : currentTime + delayPeriod^(failCount-1),
where failCount = 1, 2, 3, ...
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.