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

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

Modifier and Type	Field	Description
static KafkaSpoutRetryService	KafkaSpoutConfig.DEFAULT_RETRY_SERVICE

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

Modifier and Type	Method	Description
KafkaSpoutRetryService	KafkaSpoutConfig.getRetryService()
protected KafkaSpoutRetryService	KafkaSpoutTopologyMainNamedTopics.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.