Uses of Enum
org.apache.storm.kafka.spout.FirstPollOffsetStrategy
Packages that use FirstPollOffsetStrategy
-
Uses of FirstPollOffsetStrategy in org.apache.storm.kafka.spout
Methods in org.apache.storm.kafka.spout that return FirstPollOffsetStrategyModifier and TypeMethodDescriptionstatic FirstPollOffsetStrategy
Returns the enum constant of this type with the specified name.static FirstPollOffsetStrategy[]
FirstPollOffsetStrategy.values()
Returns an array containing the constants of this enum type, in the order they are declared. -
Uses of FirstPollOffsetStrategy in org.apache.storm.kafka.spout.internal
Fields in org.apache.storm.kafka.spout.internal declared as FirstPollOffsetStrategyModifier and TypeFieldDescriptionstatic final FirstPollOffsetStrategy
CommonKafkaSpoutConfig.DEFAULT_FIRST_POLL_OFFSET_STRATEGY
Methods in org.apache.storm.kafka.spout.internal that return FirstPollOffsetStrategyMethods in org.apache.storm.kafka.spout.internal with parameters of type FirstPollOffsetStrategyModifier and TypeMethodDescriptionCommonKafkaSpoutConfig.Builder.setFirstPollOffsetStrategy
(FirstPollOffsetStrategy firstPollOffsetStrategy) Sets the offset used by the Kafka spout in the first poll to Kafka broker upon process start.