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 and Description
class	KafkaSpoutRetryExponentialBackoff Implementation of KafkaSpoutRetryService using the exponential backoff formula.

Fields in org.apache.storm.kafka.spout declared as KafkaSpoutRetryService

Modifier and Type	Field and Description
static KafkaSpoutRetryService	KafkaSpoutConfig.DEFAULT_RETRY_SERVICE

Methods in org.apache.storm.kafka.spout that return KafkaSpoutRetryService

Modifier and Type	Method and Description
protected KafkaSpoutRetryService	KafkaSpoutTopologyMainNamedTopics.getRetryService()
KafkaSpoutRetryService	KafkaSpoutConfig.getRetryService()

Methods in org.apache.storm.kafka.spout with parameters of type KafkaSpoutRetryService

Modifier and Type	Method and Description
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setRetry(KafkaSpoutRetryService retryService) Sets the retry service for the spout to use.