 (defn- dashboard [req]
   (render-tpl "dashboard.vm"
               :instance (u/stringfy-map-keys (instance))
-              :version (u/stringfy-map-keys (version)) 
+              :version (u/stringfy-map-keys (version))
               :jvm (u/stringfy-map-keys (jvm))
               :system (u/stringfy-map-keys (system))))
 

                               owner (ZkUtils/readDataMaybeNull zc owner-znode)]
                           (when (or msg-store (seq owner))
                             (let [consumer-offset (if (seq offset-str)
                                                     (Integer/valueOf
                                                      (if (.contains offset-str "-")
                                                        (let [idx (.lastIndexOf offset-str "-")]
                                                          (.substring offset-str (inc idx)))


(defn- skip-pending-msgs [req]
  (let [{:keys [topic group partition]} (-> req :params)
        partition (Long/valueOf ^String partition)
        ^MetaZookeeper mz (with-broker (.getBrokerZooKeeper) (.getMetaZookeeper))
        ^ZkClient zc (.getZkClient mz)
        broker-id (with-broker (.getMetaConfig) (.getBrokerId))
