An opinionated clojure framework for writing kafka machines - View it on GitHub