Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2380#discussion_r146326949
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
---
@@ -78,17 +78,17 @@
private transient KafkaSpoutRetryService retryService;
// Handles tuple events (emit, ack etc.)
private transient KafkaTupleListener tupleListener;
- // timer == null for modes other than at-least-once
+ // timer == null if processing guarantee is other than at-least-once
--- End diff --
Probably nicer to write "if processing guarantee is not at-least-once"
---
