Package org.apache.kafka.common.security.oauthbearer.secured

Class Retry<R>

java.lang.Object

org.apache.kafka.common.security.oauthbearer.secured.Retry<R>

Type Parameters:

R - Result type

public class Retry<R>
extends Object

Retry encapsulates the mechanism to perform a retry and then exponential backoff using provided wait times between attempts.

Constructor Summary

Constructors

Constructor	Description
Retry(long retryBackoffMs, long retryBackoffMaxMs)
Retry(org.apache.kafka.common.utils.Time time, long retryBackoffMs, long retryBackoffMaxMs)

Method Summary

Modifier and Type	Method	Description
R	execute(Retryable<R> retryable)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Retry

public Retry(long retryBackoffMs,
 long retryBackoffMaxMs)

Retry

public Retry(org.apache.kafka.common.utils.Time time,
 long retryBackoffMs,
 long retryBackoffMaxMs)

Method Details

execute

public R execute(Retryable<R> retryable)
          throws ExecutionException

Throws:

ExecutionException