Class KafkaAuthStore.BackOffDecorator<T>

java.lang.Object

io.confluent.security.auth.store.kafka.KafkaAuthStore.BackOffDecorator<T>

Enclosing class:

KafkaAuthStore

public static class KafkaAuthStore.BackOffDecorator<T>
extends Object

Constructor Summary

Constructors

Constructor	Description
BackOffDecorator(Duration timeout, int maxAttempts)

Method Summary

Modifier and Type	Method	Description
void	close()
CompletableFuture<T>	withBackOff(Supplier<T> supplier, Predicate<Exception> predicate)

Methods inherited from class java.lang.Object

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

Constructor Details

BackOffDecorator

public BackOffDecorator(Duration timeout,
 int maxAttempts)

Method Details

withBackOff

public CompletableFuture<T> withBackOff(Supplier<T> supplier,
 Predicate<Exception> predicate)

close

public void close()