I feel like if the problem for which the module in the OP was a regular, recurring one like you've described, Storm[1] seems like it would fit. It uses Zookeepe

I feel like if the problem for which the module in the OP was a regular, recurring one like you've described, Storm[1] seems like it would fit. It uses Zookeeper to manage state and maintains strong ordering[2]. 1. https://github.com/nathanmarz/storm/wiki https://github.com/nathanmarz/storm/wiki 2. https://github.com/nathanmarz/storm/wiki/Transactional-topologies https://github.com/nathanmarz/storm/wiki/Transactional-topol...