Clojure Library for kafka-websockets tranforms