Uses of Enum
org.apache.storm.kafka.spout.KafkaSpoutConfig.ProcessingGuarantee
-
Uses of KafkaSpoutConfig.ProcessingGuarantee in org.apache.storm.kafka.spout
Modifier and TypeFieldDescriptionstatic final KafkaSpoutConfig.ProcessingGuarantee
KafkaSpoutConfig.DEFAULT_PROCESSING_GUARANTEE
Modifier 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.Modifier 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
ModifierConstructorDescriptionCommitMetadataManager
(TopologyContext context, KafkaSpoutConfig.ProcessingGuarantee processingGuarantee) Create a manager with the given context.