Github user hmcl commented on a diff in the pull request: https://github.com/apache/storm/pull/2380#discussion_r147012706 --- 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 -- Done
---