Uses of Class
org.apache.storm.kafka.spout.FirstPollOffsetStrategy
-
Packages that use FirstPollOffsetStrategy Package Description org.apache.storm.kafka.spout org.apache.storm.kafka.spout.internal -
-
Uses of FirstPollOffsetStrategy in org.apache.storm.kafka.spout
Methods in org.apache.storm.kafka.spout that return FirstPollOffsetStrategy Modifier and Type Method Description static FirstPollOffsetStrategy
FirstPollOffsetStrategy. valueOf(String name)
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 FirstPollOffsetStrategy Modifier and Type Field Description static FirstPollOffsetStrategy
CommonKafkaSpoutConfig. DEFAULT_FIRST_POLL_OFFSET_STRATEGY
Methods in org.apache.storm.kafka.spout.internal that return FirstPollOffsetStrategy Modifier and Type Method Description FirstPollOffsetStrategy
CommonKafkaSpoutConfig. getFirstPollOffsetStrategy()
Methods in org.apache.storm.kafka.spout.internal with parameters of type FirstPollOffsetStrategy Modifier and Type Method Description T
CommonKafkaSpoutConfig.Builder. setFirstPollOffsetStrategy(FirstPollOffsetStrategy firstPollOffsetStrategy)
Sets the offset used by the Kafka spout in the first poll to Kafka broker upon process start.
-