Class RetriableAvroGenericStoreClient<K,​V>

  • All Implemented Interfaces:
    AvroGenericReadComputeStoreClient<K,​V>, AvroGenericStoreClient<K,​V>,, java.lang.AutoCloseable
    Direct Known Subclasses:

    public class RetriableAvroGenericStoreClient<K,​V>
    extends DelegatingAvroStoreClient<K,​V>
    This class is mostly used to trigger retry in the following scenarios: 1. The original request latency exceeds the retry threshold. 2. The original request fails. TODO: 1. Limit the retry volume. 2. Leverage some smart logic to avoid useless retry, such as retry triggered by heavy GC.