 
 (defn event-routes
   [config [type project]]
-  (println type project)
   (let [msgs (kafka-stream (:zookeeper config) type project)
         db-ent (ent config type project)]
     (GET (str "/events/" type "/" project) [:as req] (handle-request msgs db-ent type project))))

  (:require [clj-kafka.core :refer [with-resource]]
            [cheshire.core :refer [parse-string generate-string]]
            [clojure.core.match :refer [match]]
            [clojure.core.async :refer [go <! filter< map< dropping-buffer chan close! go-loop >!]]
            [zoo-live.web.resp :refer :all]
            [korma.core :refer :all]
            [clojure.string :as str]

(defn kafka-stream
  [zk type project]
  (let [conf (kafka-config zk) 
        topic (str "events_" type "_" project)
        msgs (messages (consumer conf) [topic]) 
        channel (chan)]
    (go (doseq [m msgs] (>! channel m)))
    (pub channel (fn [_] true))))

(defn db-response
  [ent params]
