We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
FirehoseProducer
Currently, FirehoseProducer performs linear backoff via:
//Full Jitter: https://aws.amazon.com/blogs/architecture/exponential-backoff-and-jitter/ long timeToSleep = RandomUtils.nextLong(0, Math.min(configuration.getMaxBackOffInMillis(), (configuration.getBaseBackOffInMillis() * 2 * attempts)));
While the code comment points to https://aws.amazon.com/blogs/architecture/exponential-backoff-and-jitter/, it fails to implement exponentiation:
Compare this with this code from FullJitterBackoff's calculateFullJitterBackoff:
FullJitterBackoff
public long calculateFullJitterBackoff(long baseMillis, long maxMillis, double power, int attempt) { long exponentialBackoff = (long) Math.min(maxMillis, baseMillis * Math.pow(power, attempt)); return (long) (seed.nextDouble() * exponentialBackoff); }
The text was updated successfully, but these errors were encountered:
Thank you for reporting the issue. We will plan this into our upcoming releases.
Sorry, something went wrong.
AdaptivePollingRecordPublisher
No branches or pull requests
Currently,
FirehoseProducer
performs linear backoff via:While the code comment points to https://aws.amazon.com/blogs/architecture/exponential-backoff-and-jitter/, it fails to implement exponentiation:
Compare this with this code from
FullJitterBackoff
's calculateFullJitterBackoff:The text was updated successfully, but these errors were encountered: