 
   kafka-state
 
+  (commit-offsets! kafka-state)
+
   )

    topics-conf)))

(defn refresh-fetching-specs [{:keys [topics zk metadata] :as state}]
  (update-in state [:fetching] merge (fetching-specs topics zk metadata)))


;; TODO: REVIEW DOC-STRING
(defn- consumer-offsets
  "Returns the stored consumer offset in zookeeper for the provided group-id.
   This offset is stored in the zookeeper location
           /consumers/<group-id>/offsets/<topic>/<partition-id>





(comment

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