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 (or I'm completely missing something)
The short of it is I'm wondering if the line linked below 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?
