Uses of Interface
org.apache.storm.kafka.spout.KafkaSpoutRetryService
-
Packages that use KafkaSpoutRetryService Package Description org.apache.storm.kafka.spout -
-
Uses of KafkaSpoutRetryService in org.apache.storm.kafka.spout
Classes in org.apache.storm.kafka.spout that implement KafkaSpoutRetryService Modifier and Type Class Description classKafkaSpoutRetryExponentialBackoffImplementation ofKafkaSpoutRetryServiceusing the exponential backoff formula.Fields in org.apache.storm.kafka.spout declared as KafkaSpoutRetryService Modifier and Type Field Description static KafkaSpoutRetryServiceKafkaSpoutConfig. DEFAULT_RETRY_SERVICEMethods in org.apache.storm.kafka.spout that return KafkaSpoutRetryService Modifier and Type Method Description KafkaSpoutRetryServiceKafkaSpoutConfig. getRetryService()protected KafkaSpoutRetryServiceKafkaSpoutTopologyMainNamedTopics. getRetryService()Methods in org.apache.storm.kafka.spout with parameters of type KafkaSpoutRetryService Modifier and Type Method Description KafkaSpoutConfig.Builder<K,V>KafkaSpoutConfig.Builder. setRetry(KafkaSpoutRetryService retryService)Sets the retry service for the spout to use.
-