 
 
 
+
 (comment
 
   (set-zk-connection! kafka-state {"zookeeper.connect" "docker:49153" :group-id "some-consumer-id" :fetch-size 1024000})



(defn refresh-consumer-offsets [{:keys [zk] :as state}]
  (update-in state [:fetching] #(consumer-offsets zk %)))


(defmacro forever-do [name sleep & body]


  kafka-state

  (commit-offsets! kafka-state)

  )
