Uses of Interface
org.apache.storm.kafka.spout.KafkaSpoutRetryService
Packages that use KafkaSpoutRetryService
-
Uses of KafkaSpoutRetryService in org.apache.storm.kafka.spout
Classes in org.apache.storm.kafka.spout that implement KafkaSpoutRetryServiceModifier and TypeClassDescriptionclassImplementation ofKafkaSpoutRetryServiceusing the exponential backoff formula.Fields in org.apache.storm.kafka.spout declared as KafkaSpoutRetryServiceModifier and TypeFieldDescriptionstatic final KafkaSpoutRetryServiceKafkaSpoutConfig.DEFAULT_RETRY_SERVICEMethods in org.apache.storm.kafka.spout that return KafkaSpoutRetryServiceModifier and TypeMethodDescriptionKafkaSpoutConfig.getRetryService()protected KafkaSpoutRetryServiceKafkaSpoutTopologyMainNamedTopics.getRetryService()Methods in org.apache.storm.kafka.spout with parameters of type KafkaSpoutRetryServiceModifier and TypeMethodDescriptionKafkaSpoutConfig.Builder.setRetry(KafkaSpoutRetryService retryService) Sets the retry service for the spout to use.