Uses of Class
org.apache.storm.kafka.spout.KafkaSpoutConfig.ProcessingGuarantee

Packages that use KafkaSpoutConfig.ProcessingGuarantee

Package	Description
org.apache.storm.kafka.spout
org.apache.storm.kafka.spout.internal

Uses of KafkaSpoutConfig.ProcessingGuarantee in org.apache.storm.kafka.spout

Fields in org.apache.storm.kafka.spout declared as KafkaSpoutConfig.ProcessingGuarantee

Modifier and Type	Field and Description
static KafkaSpoutConfig.ProcessingGuarantee	KafkaSpoutConfig.DEFAULT_PROCESSING_GUARANTEE

Methods in org.apache.storm.kafka.spout that return KafkaSpoutConfig.ProcessingGuarantee

Modifier and Type	Method and Description
KafkaSpoutConfig.ProcessingGuarantee	KafkaSpoutConfig.getProcessingGuarantee()
static KafkaSpoutConfig.ProcessingGuarantee	KafkaSpoutConfig.ProcessingGuarantee.valueOf(String name) 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.ProcessingGuarantee

Modifier and Type	Method and Description
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.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.ProcessingGuarantee

Constructor and Description
CommitMetadataManager(TopologyContext context, KafkaSpoutConfig.ProcessingGuarantee processingGuarantee) Create a manager with the given context.