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 and 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 and Description
static FirstPollOffsetStrategy	CommonKafkaSpoutConfig.DEFAULT_FIRST_POLL_OFFSET_STRATEGY

Methods in org.apache.storm.kafka.spout.internal that return FirstPollOffsetStrategy

Modifier and Type	Method and Description
FirstPollOffsetStrategy	CommonKafkaSpoutConfig.getFirstPollOffsetStrategy()

Methods in org.apache.storm.kafka.spout.internal with parameters of type FirstPollOffsetStrategy

Modifier and Type	Method and 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.