public static class KafkaAuthStore.BackOffDecorator<T> extends Object
Constructor and Description |
---|
BackOffDecorator(Duration timeout,
int maxAttempts) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
CompletableFuture<T> |
withBackOff(Supplier<T> supplier,
Predicate<Exception> predicate) |