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