Hi, Just thought I'll put this out for the kafka community to see (if anyone finds it useful great!!).
Kafka-fast is 100% pure clojure implementation for kafka, but not just meant for clojure because it has a Java API wrapper that can be used from Java, Groovy, JRuby or Scala. This library does not wrap scala instead it directly communicates with the kafka cluster. It also uses redis for offsets instead of zookeeper and removes the one consumer per partition limit that all other kafka libraries have, by diving offsets into logical work units and running consumption via a queue(list) in redis. https://github.com/gerritjvv/kafka-fast Any constructive critique is more than welcome :)