Uses of Enum
org.apache.storm.kafka.spout.KafkaSpoutConfig.ProcessingGuarantee
Packages that use KafkaSpoutConfig.ProcessingGuarantee
-
Uses of KafkaSpoutConfig.ProcessingGuarantee in org.apache.storm.kafka.spout
Fields in org.apache.storm.kafka.spout declared as KafkaSpoutConfig.ProcessingGuaranteeModifier and TypeFieldDescriptionstatic final KafkaSpoutConfig.ProcessingGuarantee
KafkaSpoutConfig.DEFAULT_PROCESSING_GUARANTEE
Methods in org.apache.storm.kafka.spout that return KafkaSpoutConfig.ProcessingGuaranteeModifier and TypeMethodDescriptionKafkaSpoutConfig.getProcessingGuarantee()
Returns the enum constant of this type with the specified name.static KafkaSpoutConfig.ProcessingGuarantee[]
KafkaSpoutConfig.ProcessingGuarantee.values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.apache.storm.kafka.spout with parameters of type KafkaSpoutConfig.ProcessingGuaranteeModifier and TypeMethodDescriptionKafkaSpoutConfig.Builder.setProcessingGuarantee
(KafkaSpoutConfig.ProcessingGuarantee processingGuarantee) Specifies which processing guarantee the spout should offer. -
Uses of KafkaSpoutConfig.ProcessingGuarantee in org.apache.storm.kafka.spout.internal
Constructors in org.apache.storm.kafka.spout.internal with parameters of type KafkaSpoutConfig.ProcessingGuaranteeModifierConstructorDescriptionCommitMetadataManager
(TopologyContext context, KafkaSpoutConfig.ProcessingGuarantee processingGuarantee) Create a manager with the given context.