Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2911#discussion_r234541339
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java
---
@@ -137,7 +142,11 @@ public KafkaSpoutConfig(Builder<K, V> builder) {
/**
* The kafka spout polls records from the last committed offset,
if any. If no offset has been committed it behaves as LATEST
*/
- UNCOMMITTED_LATEST;
+ UNCOMMITTED_LATEST,
+ /**
+ * Start at the earliest offset whose timestamp is greater than or
equal to the given startTimestamp
+ */
+ TIMESTAMP;
--- End diff --
I'm wondering if it would be useful to have both TIMESTAMP and
UNCOMMITTED_TIMESTAMP?
---
