Github user hmcl commented on a diff in the pull request:
https://github.com/apache/storm/pull/2465#discussion_r157375663
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java
---
@@ -134,7 +134,12 @@ public KafkaSpoutConfig(Builder<K, V> builder) {
EARLIEST,
LATEST,
UNCOMMITTED_EARLIEST,
- UNCOMMITTED_LATEST
+ UNCOMMITTED_LATEST;
+
+ @Override
+ public String toString() {
+ return "FirstPollOffsetStrategy{" + super.toString() + "}";
--- End diff --
```
Seeking offset for topic-partition a1p-0 with
FirstPollOffsetStrategy{UNCOMMITTED_EARLIEST} and OffsetAndMetadata{offset=3,
metadata='{"topologyId":"tpn-1-1513534208","taskId":3,"threadName":"Thread-20-ks-executor[3
3]"}'}
```
---
