A simple Clojure library for processing Kafka streams using core.async