Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2465#discussion_r157816130
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java
---
@@ -115,26 +115,30 @@ public KafkaSpoutConfig(Builder<K, V> builder) {
}
/**
- * The offset used by the Kafka spout in the first poll to Kafka
broker. The choice of this parameter will affect the number of consumer
- * records returned in the first poll. By default this parameter is
set to UNCOMMITTED_EARLIEST. <br/><br/>
+ * Defines the offset used by the {@link KafkaSpout} in the first poll
to Kafka broker. The choice of this parameter will affect
+ * the number of consumer records returned in the first poll. By
default this parameter is set to UNCOMMITTED_EARLIEST. <br/><br/>
* The allowed values are EARLIEST, LATEST, UNCOMMITTED_EARLIEST,
UNCOMMITTED_LATEST. <br/>
* <ul>
- * <li>EARLIEST means that the kafka spout polls records starting in
the first offset of the partition, regardless of previous
- * commits</li>
- * <li>LATEST means that the kafka spout polls records with offsets
greater than the last offset in the partition, regardless of
- * previous commits</li>
+ * <li>EARLIEST when the topology is first deployed the kafka spout
polls records starting in the first offset of the
+ * partition, regardless of previous commits. When the topology is
activated/deactivated this setting has no effect</li>
+ * <li>LATEST when the topology is first deployed the kafka spout
polls records with offsets greater than the last offset
+ * in the partition, regardless of previous commits. If the topology
is activated/deactivated this setting has no effect</li>
* <li>UNCOMMITTED_EARLIEST means that the kafka spout polls records
from the last committed offset, if any. If no offset has been
* committed, it behaves as EARLIEST.</li>
* <li>UNCOMMITTED_LATEST means that the kafka spout polls records
from the last committed offset, if any. If no offset has been
* committed, it behaves as LATEST.</li>
* </ul>
- *
*/
- public static enum FirstPollOffsetStrategy {
+ public enum FirstPollOffsetStrategy {
--- End diff --
Thanks, didn't know that.
---
