So this question may be better suited for the dev mailing list, but I'll give this a shot.
I'm trying to better understand the acker behavior and how it deals with tuple time outs. I've read the documentation on the storm website, but from my rudimentary knowledge of clojure, it seems like the docs and the code don't completely align. The short of it is I'm wondering if the line linked in acker.clj resets the tuple timeout value every time a bolt acks a tuple: https://github.com/apache/storm/blob/master/storm-core/src/clj/backtype/storm/daemon/acker.clj#L65 It seems like for every tuple coming into the acker, it calls rotatingMap.put() on the instance, which in turn resets its timeout countdown. Does this sound correct?
