Uses of Enum
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 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
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.